在Linux或Windows环境下编写程序,建立若干个生产者进程和若干个消费者进程,其中生产者和消费者之间通过一个长度为10的缓冲区进行通信,缓冲区为临界资源。编写一个c语言程序实现生产者和消费者之间的同步以及生产者和生产者之间、消费者和消费者之间、生产者和消费者之间的互斥。
时间: 2024-05-12 17:17:17 浏览: 126
您好!谢谢您的问题。根据您的描述,我可以为您提供以下c语言程序的实现:
```
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>
#define BUFFER_SIZE 10 // 缓冲区大小
#define PRODUCER_NUM 5 // 生产者数量
#define CONSUMER_NUM 3 // 消费者数量
#define PRODUCE_TIMES 20 // 生产次数
#define CONSUME_TIMES 15 // 消费次数
typedef struct {
int buffer[BUFFER_SIZE]; // 缓冲区
int in; // 生产者写入数据的位置
int out; // 消费者读取数据的位置
pthread_cond_t full; // 缓冲区满
pthread_cond_t empty; // 缓冲区空
pthread_mutex_t mutex; // 互斥锁
} BUFFER;
BUFFER buffer;
void *producer(void *param);
void *consumer(void *param);
int main(int argc, char *argv[]) {
printf("生产者-消费者问题解决方案\n");
pthread_t p_tid[PRODUCER_NUM], c_tid[CONSUMER_NUM];
pthread_mutex_init(&buffer.mutex, NULL);
pthread_cond_init(&buffer.empty, NULL);
pthread_cond_init(&buffer.full, NULL);
buffer.in = 0;
buffer.out = 0;
int i, prod_id[PRODUCER_NUM], cons_id[CONSUMER_NUM];
// 创建生产者进程
for (i = 0; i < PRODUCER_NUM; i++) {
prod_id[i] = i;
pthread_create(&p_tid[i], NULL, producer, &prod_id[i]);
}
// 创建消费者进程
for (i = 0; i < CONSUMER_NUM; i++) {
cons_id[i] = i;
pthread_create(&c_tid[i], NULL, consumer, &cons_id[i]);
}
// 等待所有进程执行完毕
for (i = 0; i < PRODUCER_NUM; i++) {
pthread_join(p_tid[i], NULL);
}
for (i = 0; i < CONSUMER_NUM; i++) {
pthread_join(c_tid[i], NULL);
}
// 销毁互斥锁和信号量
pthread_mutex_destroy(&buffer.mutex);
pthread_cond_destroy(&buffer.empty);
pthread_cond_destroy(&buffer.full);
return 0;
}
void *producer(void *param) {
int id = *(int *)param;
int i, data;
for (i = 0; i < PRODUCE_TIMES; i++) {
// 生产数据
data = rand() % 100;
// 加锁互斥
pthread_mutex_lock(&buffer.mutex);
// 如果缓冲区已满,等待
while ((buffer.in + 1) % BUFFER_SIZE == buffer.out) {
printf("生产者-%d 等待缓冲区空...\n", id);
pthread_cond_wait(&buffer.empty, &buffer.mutex);
}
// 放入数据
buffer.buffer[buffer.in] = data;
printf("生产者-%d 生产数据:%d\n", id, data);
// 队尾指针移至下一位
buffer.in = (buffer.in + 1) % BUFFER_SIZE;
// 通知消费者缓冲区不为空
pthread_cond_signal(&buffer.full);
// 解锁互斥
pthread_mutex_unlock(&buffer.mutex);
// 随机睡眠
sleep(rand() % 3);
}
pthread_exit(0);
}
void *consumer(void *param) {
int id = *(int *)param;
int i, data;
for (i = 0; i < CONSUME_TIMES; i++) {
// 加锁互斥
pthread_mutex_lock(&buffer.mutex);
// 如果缓冲区已空,等待
while (buffer.in == buffer.out) {
printf("消费者-%d 等待缓冲区不空...\n", id);
pthread_cond_wait(&buffer.full, &buffer.mutex);
}
// 取出数据
data = buffer.buffer[buffer.out];
printf("消费者-%d 消费数据:%d\n", id, data);
// 队头指针移至下一位
buffer.out = (buffer.out + 1) % BUFFER_SIZE;
// 通知生产者缓冲区不满
pthread_cond_signal(&buffer.empty);
// 解锁互斥
pthread_mutex_unlock(&buffer.mutex);
// 随机睡眠
sleep(rand() % 3);
}
pthread_exit(0);
}
```
以上实现从`buffer.mutex`的加锁和解锁操作,以及`buffer.full`和`buffer.empty`的等待和唤醒操作等方面保证了同步和互斥。同时也保证了生产者和消费者之间、生产者和生产者之间、消费者和消费者之间的互斥关系,从而解决了生产者-消费者问题。如果您有任何问题,请随时问我。
阅读全文