1.生产者消费者问题(信号量) 参考教材中的生产者消费者算法,创建5个进程,其中两个进程为生产者进程,3个进程为消费者进程。一个生产者进程试图不断地在一个缓冲中写入大写字母,另一个生产者进程试图不断地在缓冲中写入小写字母。3个消费者不断地从缓冲中读取一个字符并输出。为了使得程序的输出易于看到结果,仿照的实例程序,分别在生产者和消费者进程的合适的位置加入一些随机睡眠时间。 可选的实验:在上面实验的基础上实现部分消费者有选择地消费某些产品。例如一个消费者只消费小写字符,一个消费者只消费大写字母,而另一个消费者则无选择地消费任何产品。消费者要消费的产品没有时,消费者进程被阻塞。注意缓冲的管理。C语言实现,尽量不要用指针,也不要用特别复杂的数据结构,代码尽量写的通俗易懂,提供源代码、思路、总结、遇到的问题。
时间: 2024-02-16 21:03:03 浏览: 68
好的,我知道了。这是一个经典的生产者消费者问题,我会尽力回答你的问题。首先,我们需要定义一个缓冲区,用于存储生产者生产的数据,消费者从缓冲区中取出数据进行消费。缓冲区可以使用一个数组来实现。
接下来,我们需要使用信号量来实现同步和互斥。定义三个信号量:empty、full和mutex,分别表示缓冲区为空、缓冲区为满和互斥。当empty=0时,生产者进程需要等待;当full=0时,消费者进程需要等待;当mutex=0时,其他进程需要等待。
接下来,我们来看一下代码实现。
```
#include<semaphore.h>
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<time.h>
#include<sys/types.h>
#include<sys/wait.h>
#define BUFFER_SIZE 10
#define PRODUCER_NUM 2
#define CONSUMER_NUM 3
char buffer[BUFFER_SIZE];
int in = 0;
int out = 0;
sem_t empty;
sem_t full;
sem_t mutex;
void* producer(void* arg)
{
int id = *(int*)arg;
while (1)
{
char item;
if (id == 0)
{
item = 'A' + rand() % 26;
}
else
{
item = 'a' + rand() % 26;
}
sleep(rand() % 3);
sem_wait(&empty);
sem_wait(&mutex);
buffer[in] = item;
in = (in + 1) % BUFFER_SIZE;
printf("Producer %d produces item %c\n", id, item);
sem_post(&mutex);
sem_post(&full);
}
}
void* consumer(void* arg)
{
int id = *(int*)arg;
while (1)
{
sleep(rand() % 3);
sem_wait(&full);
sem_wait(&mutex);
char item = buffer[out];
out = (out + 1) % BUFFER_SIZE;
printf("Consumer %d consumes item %c\n", id, item);
sem_post(&mutex);
sem_post(&empty);
}
}
int main()
{
srand(time(NULL));
sem_init(&empty, 0, BUFFER_SIZE);
sem_init(&full, 0, 0);
sem_init(&mutex, 0, 1);
pthread_t producers[PRODUCER_NUM];
pthread_t consumers[CONSUMER_NUM];
int producer_ids[PRODUCER_NUM];
int consumer_ids[CONSUMER_NUM];
for (int i = 0; i < PRODUCER_NUM; i++)
{
producer_ids[i] = i;
pthread_create(&producers[i], NULL, producer, &producer_ids[i]);
}
for (int i = 0; i < CONSUMER_NUM; i++)
{
consumer_ids[i] = i;
pthread_create(&consumers[i], NULL, consumer, &consumer_ids[i]);
}
for (int i = 0; i < PRODUCER_NUM; i++)
{
pthread_join(producers[i], NULL);
}
for (int i = 0; i < CONSUMER_NUM; i++)
{
pthread_join(consumers[i], NULL);
}
sem_destroy(&empty);
sem_destroy(&full);
sem_destroy(&mutex);
return 0;
}
```
在主函数中,首先初始化三个信号量empty、full和mutex,然后创建producer和consumer线程,使用pthread_create函数。在创建线程时,我们传递一个指向整数的指针作为参数,该整数表示线程的ID。
producer线程不断地在缓冲区中写入字符,使用rand函数生成大写或小写字符,并将它们写入缓冲区。然后,线程休眠一段随机时间,以模拟生产者生产数据的时间。在写入缓冲区之前,需要使用sem_wait函数申请empty和mutex信号量。当empty=0或mutex=0时,线程被阻塞。当写入缓冲区后,释放mutex和full信号量,以便其他线程可以继续执行。
consumer线程不断地从缓冲区中读取字符,使用sem_wait函数申请full和mutex信号量。当full=0或mutex=0时,线程被阻塞。然后,从缓冲区中读取字符,并将其打印出来。最后,释放mutex和empty信号量,以便其他线程可以继续执行。
在主函数中,使用pthread_join函数等待线程结束,并使用sem_destroy函数销毁信号量。
总结:本实验中,我们使用信号量来实现生产者消费者问题。通过定义三个信号量empty、full和mutex,实现了同步和互斥。缓冲区使用数组来实现,线程使用pthread库中的函数来创建和管理。在实现中,需要注意信号量的申请和释放顺序,以及缓冲区的管理。
遇到的问题:在实现过程中,需要注意信号量的使用,例如在生产者和消费者线程中正确地申请和释放信号量。还需要注意缓冲区的管理,例如在写入和读取缓冲区时需要正确地维护in和out指针。
阅读全文