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

1、操作系統(tǒng)的一個經(jīng)典問題是生產(chǎn)者-消費者問題,這涉及同步信號量和互斥信號量的應用,在這里,我用線程的同步和互斥來實現(xiàn)./*author張文*2008/06/20*/#include#include#include#include#include#defineN2/消費者或者生產(chǎn)者的數(shù)目#defineM10/緩沖數(shù)目intin=0;/生產(chǎn)者放置產(chǎn)品的位置intout=0;/消費者取產(chǎn)品的位置intbuffM=0;/緩沖初始化為0，開始時沒有產(chǎn)品sem_tempty_sem;/同步信號量，當滿了時阻止生產(chǎn)者放產(chǎn)品sem_tfull_sem;/同步信號量，當沒產(chǎn)品時阻止消費者消費pthread_mut

2、ex_tmutex;/互斥信號量，一次只有一個線程訪問緩沖intproduct_id=0;/生產(chǎn)者idintprochase_id=0;/消費者id/*打印緩沖情況*/voidprint()inti;for(i=0;iM;i+)printf(%d,buffi);printf(n);/*生產(chǎn)者方法*/void*product()intid=+product_id;while(1)/用sleep的數(shù)量可以調節(jié)生產(chǎn)和消費的速度，便于觀察sleep(1);/sleep(1);sem_wait(&empty_sem);pthread_mutex_lock(&mutex);in=in%M;printf(p

3、roduct%din%d.like:t,id,in);buffin=1;print();+in;pthread_mutex_unlock(&mutex);sem_post(&full_sem);/*消費者方法*/void*prochase()intid=+prochase_id;while(1)/用sleep的數(shù)量可以調節(jié)生產(chǎn)和消費的速度，便于觀察sleep(1);/sleep(1);sem_wait(&full_sem);pthread_mutex_lock(&mutex);out=out%M;printf(prochase%din%d.like:t,id,out);buffout=0;pr

4、int();+out;pthread_mutex_unlock(&mutex);sem_post(&empty_sem);intmain()pthread_tid1N;pthread_tid2N;inti;intretN;/初始化同步信號量intini1=sem_init(&empty_sem,0,M);intini2=sem_init(&full_sem,0,0);if(ini1&ini2!=0)printf(seminitfailedn);exit(1);/初始化互斥信號量intini3=pthread_mutex_init(&mutex,NULL);if(ini3!=0)printf(m

5、utexinitfailedn);exit(1);/創(chuàng)建N個生產(chǎn)者線程for(i=0;iN;i+)(voidreti=pthread_create(&id1i,NULL,product,*)(&i);(voidif(reti!=0)printf(product%dcreationfailedn,i);exit(1);/創(chuàng)建N個消費者線程for(i=0;iN;i+)reti=pthread_create(&id2i,NULL,prochase,NULL);if(reti!=0)printf(prochase%dcreationfailedn,i);exit(1);/銷毀線程for(i=0;iN;i+)pthread_join(id1i,NULL);pthread_join(id2i,NULL);exit(0);關于這個程序中的同步和互斥操作，很多網(wǎng)上資料都說必須先同步再互斥，否則會有死鎖，我認為這是錯的。事實上，生產(chǎn)者中先同步再互斥，而消費者先互斥再同步，或反之；以及生產(chǎn)者和消費者都先互斥再