操作系统生产者消费者问题代码.doc

《操作系统生产者消费者问题代码.doc》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、#include#include#include#include#include//声明所需变量intin=0;intout=0;HANDLEh_Thread[20];//线程数组HANDLEempty_Semaphore;//表示空缓冲区的信号量HANDLEfull_Semaphore;//表示空缓冲区的信号量HANDLEmutex;structdata{intID;//序号chartype;//类型，是生产者还是消费者

2、,porcdoubledelay;//线程延迟的时间，对应生产者生产产品的时间或消费者消费产品的时间};dataThreadInfo[20];//线程信息数组intlength;//线程信息数组中实际的线程个数voidProduce(void*p);//生产者进程voidConsume(void*p);//消费者进程voidinput(void);intmain(void){input();//初始化临界区对象//InitializeCriticalSection(&PC_Critical);empty_Semaphore

3、=CreateSemaphore(NULL,10,10,NULL);full_Semaphore=CreateSemaphore(NULL,0,10,NULL);mutex=::CreateMutex(NULL,FALSE,NULL);cout<<"下面生产者和消费者开始工作!!"<

4、D_START_ROUTINE)(Produce),&(ThreadInfo[i]),0,NULL);elseh_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Consume),&(ThreadInfo[i]),0,NULL);}//主程序等待各个线程的动作结束WaitForMultipleObjects(length,h_Thread,TRUE,-1);cout<

5、ndl<

6、*********************************************************//消费者进程//******************************************************************************************voidConsume(void*p){//局部变量声明intmy_id;doublemy_delay;//从线程信息数组中获得信息my_id=((data*)(p))->ID;my_delay=((data*)(p

7、))->delay;//开始请求xiaofeicout<<"消费者"<

8、my_id<<"完成了消费。"<