c語言實現(xiàn)多個生產(chǎn)者和消費者

1、精選優(yōu)質(zhì)文檔-傾情為你奉上操作系統(tǒng)的一個經(jīng)典問題是"生產(chǎn)者-消費者"問題, 這涉及同步信號量和互斥信號量的應(yīng)用, 在這里,我用線程的同步和互斥來實現(xiàn)./* author 張文* 2008/06/20*/#include <stdio.h>#include <stdlib.h>#include <unistd.h>#include <pthread.h>#include <semaphore.h>#define N 2   / 消費者或者生產(chǎn)者的數(shù)目#define M 10 /

2、 緩沖數(shù)目int in = 0;   / 生產(chǎn)者放置產(chǎn)品的位置int out = 0; / 消費者取產(chǎn)品的位置int buffM = 0; / 緩沖初始化為0， 開始時沒有產(chǎn)品sem_t empty_sem; / 同步信號量， 當滿了時阻止生產(chǎn)者放產(chǎn)品sem_t full_sem;   / 同步信號量， 當沒產(chǎn)品時阻止消費者消費pthread_mutex_t mutex; / 互斥信號量， 一次只有一個線程訪問緩沖int product_id = 0;   /生產(chǎn)者

3、idint prochase_id = 0; /消費者id/* 打印緩沖情況 */void print()int i;for(i = 0; i < M; i+)   printf("%d ", buffi);printf("n");/* 生產(chǎn)者方法 */ void *product()int id = +product_id;while(1)   / 用sleep的數(shù)量可以調(diào)節(jié)生產(chǎn)和消費的速度，便于觀察   sleep(1);   /sleep(1)

4、;     sem_wait(&empty_sem);   pthread_mutex_lock(&mutex);     in = in % M;   printf("product%d in %d. like: t", id, in);     buffin = 1;     print();     +in;

5、0;    pthread_mutex_unlock(&mutex);   sem_post(&full_sem);  /* 消費者方法 */void *prochase()int id = +prochase_id;while(1)   / 用sleep的數(shù)量可以調(diào)節(jié)生產(chǎn)和消費的速度，便于觀察   sleep(1);/sleep(1);     sem_wait(&full_sem);   pthre

6、ad_mutex_lock(&mutex);     out = out % M;   printf("prochase%d in %d. like: t", id, out);     buffout = 0;   print();   +out;     pthread_mutex_unlock(&mutex);   sem_post(&empty_

7、sem);int main()pthread_t id1N;pthread_t id2N;int i;int retN;/ 初始化同步信號量int ini1 = sem_init(&empty_sem, 0, M); int ini2 = sem_init(&full_sem, 0, 0);  if(ini1 && ini2 != 0)   printf("sem init failed n");   exit(1); /初始化互斥信號量 int ini

8、3 = pthread_mutex_init(&mutex, NULL);if(ini3 != 0)   printf("mutex init failed n");   exit(1); / 創(chuàng)建N個生產(chǎn)者線程for(i = 0; i < N; i+)   reti = pthread_create(&id1i, NULL, product, (void *)(&i);   if(reti != 0)     &#

9、160; printf("product%d creation failed n", i);    exit(1);   /創(chuàng)建N個消費者線程for(i = 0; i < N; i+)   reti = pthread_create(&id2i, NULL, prochase, NULL);   if(reti != 0)       printf("prochase%d creation failed n", i);    exit(1);   /銷毀線程for(i = 0; i < N; i+)   pthread_join(id1i,NULL);   pthread_join(id2i,NULL);exit(0); 關(guān)于這個程序中的同步和互斥操作，很多網(wǎng)上資料都說必須先同步再互斥，否則會