操作系統(tǒng)生產(chǎn)者消費者問題代碼

1、#include #include #include #include #include /聲明所需變量int in=0;int out=0;HANDLE h_Thread20; /線程數(shù)組HANDLE empty_Semaphore; /表示空緩沖區(qū)的信號量HANDLE full_Semaphore; /表示空緩沖區(qū)的信號量HANDLE mutex; struct dataint ID;/序號char type;/類型，是生產(chǎn)者還是消費者,p or cdouble delay;/線程延遲的時間，對應(yīng)生產(chǎn)者生產(chǎn)產(chǎn)品的時間或消費者消費產(chǎn)品的時間;data ThreadInfo20; /線程信息數(shù)

2、組 int length; /線程信息數(shù)組中實際的線程個數(shù)void Produce(void *p);/生產(chǎn)者進程void Consume(void *p);/消費者進程void input(void);int main(void) input(); /初始化臨界區(qū)對象 /InitializeCriticalSection(&PC_Critical); empty_Semaphore=CreateSemaphore(NULL,10,10,NULL);full_Semaphore=CreateSemaphore(NULL,0,10,NULL);mutex = :CreateMutex(NULL,

3、FALSE,NULL);cout下面生產(chǎn)者和消費者開始工作!endl;coutendl; /創(chuàng)建生產(chǎn)者和消費者線程for(int i=0;ilength;i+)if(ThreadInfoi.type=p)h_Threadi=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Produce),&(ThreadInfoi),0,NULL);else h_Threadi=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Consume),&(ThreadInfoi),0,NULL); /主程序等待各個線程的動作結(jié)束 Wa

4、itForMultipleObjects(length,h_Thread,TRUE,-1);coutendl;:Sleep();cout所有的生產(chǎn)者和消費者都完成了它們的工作!endlID; my_delay=(data*)(p)-delay;/開始請求xiaofei cout消費者my_id發(fā)出消費請求。endl;coutendl; WaitForSingleObject(full_Semaphore,-1);:WaitForSingleObject(mutex,-1); /EnterCriticalSection(&PC_Critical);cout消費者my_id消費.endl; out

5、=(out+1)%10;Sleep(my_delay*1000); cout消費者my_id完成了消費。endlendl; /LeaveCriticalSection(&PC_Critical); ReleaseSemaphore(empty_Semaphore,1,NULL);:ReleaseMutex(mutex); /*/輸入進程信息的函數(shù)/*void input(void)/定義局部變量int id; char ch;double time; int k=0; cout* 請輸入線程信息: endl;cout* 線程ID; endl;cout* 線程的類型(生產(chǎn)者線程，還是消費者線程,p代表生產(chǎn)者，c代表消費者)；endl;cout* 線程延遲時間。endl;cout* 線程ID為0時結(jié)束線程信息的輸入!endlendl;while(id!=0)coutplease input a thread ID.id;ThreadInfok.ID=id;if(id=0) break;coutplease input a thread type.ch;ThreadInfok.type=ch;coutplease input a thread delay time:time;ThreadInfok.delay=time;k+; length=k; coutendl您輸入的線程信息為 :