c語(yǔ)言實(shí)現(xiàn)多個(gè)生產(chǎn)者和消費(fèi)者

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

2、ex_tmutex;/互斥信號(hào)量，一次只有一個(gè)線程訪問緩沖intproduct_id=0;/生產(chǎn)者idintprochase_id=0;/消費(fèi)者id/*打印緩沖情況*/voidprint()inti;for(i=0;iM;i+)printf(%d,buffi);printf(n);/*生產(chǎn)者方法*/void*product()intid=+product_id;while(1)/用sleep的數(shù)量可以調(diào)節(jié)生產(chǎn)和消費(fèi)的速度，便于觀察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);/*消費(fèi)者方法*/void*prochase()intid=+prochase_id;while(1)/用sleep的數(shù)量可以調(diào)節(jié)生產(chǎn)和消費(fèi)的速度，便于觀察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;/初始化同步信號(hào)量intini1=sem_init(&empty_sem,0,M);intini2=sem_init(&full_sem,0,0);if(ini1&ini2!=0)printf(seminitfailedn);exit(1);/初始化互斥信號(hào)量intini3=pthread_mutex_init(&mutex,NULL);if(ini3!=0)printf(m

5、utexinitfailedn);exit(1);/創(chuàng)建N個(gè)生產(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個(gè)消費(fèi)者線程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);關(guān)于這個(gè)程序中的同步和互斥操作，很多網(wǎng)上資料都說必須先同步再互斥，否則會(huì)有死鎖，我認(rèn)為這是錯(cuò)的。事實(shí)上，生產(chǎn)者中先同步再互斥，而消費(fèi)者先互斥再同步，或反之；以及生產(chǎn)者和消費(fèi)者都先互斥再