自选语言编写一个程序,模拟多个生产者进程和多个消费者进程并发执行,并采用信号量
时间: 2024-02-20 11:59:55 浏览: 21
好的,我了解了。这是一个经典的生产者消费者问题,需要使用信号量来保证线程之间的同步和互斥。下面是使用C语言编写的程序,模拟多个生产者进程和多个消费者进程并发执行:
```c
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <semaphore.h>
#define BUFFER_SIZE 10 // 缓冲区大小
#define PRODUCER_NUM 3 // 生产者数量
#define CONSUMER_NUM 2 // 消费者数量
int buffer[BUFFER_SIZE]; // 缓冲区
int in = 0, out = 0; // 缓冲区读写指针
sem_t empty, full, mutex; // 信号量
void *producer(void *arg) // 生产者线程函数
{
int id = *(int *)arg;
while (1) {
sleep(rand() % 5); // 随机等待一段时间
int item = rand() % 100; // 随机生成一个物品
sem_wait(&empty); // 等待空闲缓冲区
sem_wait(&mutex); // 互斥访问缓冲区
buffer[in] = item; // 将物品放入缓冲区
printf("Producer %d produced item %d at %d\n", id, item, in);
in = (in + 1) % BUFFER_SIZE; // 更新写指针
sem_post(&mutex); // 释放互斥锁
sem_post(&full); // 发信号告诉消费者缓冲区有数据
}
pthread_exit(NULL);
}
void *consumer(void *arg) // 消费者线程函数
{
int id = *(int *)arg;
while (1) {
sleep(rand() % 5); // 随机等待一段时间
sem_wait(&full); // 等待有数据的缓冲区
sem_wait(&mutex); // 互斥访问缓冲区
int item = buffer[out]; // 从缓冲区取出物品
printf("Consumer %d consumed item %d at %d\n", id, item, out);
out = (out + 1) % BUFFER_SIZE; // 更新读指针
sem_post(&mutex); // 释放互斥锁
sem_post(&empty); // 发信号告诉生产者缓冲区有空闲
}
pthread_exit(NULL);
}
int main()
{
sem_init(&empty, 0, BUFFER_SIZE); // 初始化信号量
sem_init(&full, 0, 0);
sem_init(&mutex, 0, 1);
pthread_t producer_threads[PRODUCER_NUM]; // 生产者线程
pthread_t consumer_threads[CONSUMER_NUM]; // 消费者线程
int i, id[PRODUCER_NUM + CONSUMER_NUM];
for (i = 0; i < PRODUCER_NUM; i++) {
id[i] = i + 1;
pthread_create(&producer_threads[i], NULL, producer, &id[i]);
}
for (i = 0; i < CONSUMER_NUM; i++) {
id[PRODUCER_NUM + i] = i + 1;
pthread_create(&consumer_threads[i], NULL, consumer, &id[PRODUCER_NUM + i]);
}
for (i = 0; i < PRODUCER_NUM; i++) { // 等待线程结束
pthread_join(producer_threads[i], NULL);
}
for (i = 0; i < CONSUMER_NUM; i++) {
pthread_join(consumer_threads[i], NULL);
}
sem_destroy(&empty); // 销毁信号量
sem_destroy(&full);
sem_destroy(&mutex);
return 0;
}
```
在这个程序中,我们使用了三个信号量来解决生产者消费者问题:
- empty:表示缓冲区中空闲位置的数量,初始值为 BUFFER_SIZE。
- full:表示缓冲区中已有数据的数量,初始值为 0。
- mutex:用于互斥访问缓冲区,初始值为 1。
当生产者线程生产一个物品时,它会等待 empty 信号量,如果缓冲区中有空闲位置,它会获取 mutex 信号量来互斥访问缓冲区,并将物品放入缓冲区中,然后释放 mutex 信号量和 full 信号量。
当消费者线程消费一个物品时,它会等待 full 信号量,如果缓冲区中有数据,它会获取 mutex 信号量来互斥访问缓冲区,并将物品从缓冲区中取出,然后释放 mutex 信号量和 empty 信号量。
通过使用信号量,我们可以保证生产者线程和消费者线程之间的同步和互斥,从而避免了生产者和消费者之间的竞态条件和死锁问题。