生产者消费者算法c++版.doc

/*/* 实验一 生产者消费者问题 */*/#include #include #include const unsigned short SIZE_OF_BUFFER = 10; /缓冲队列长度unsigned short ProductID = 0; /产品号unsigned short ConsumeID = 0; /将被消耗的产品号unsigned short in = 0; /相当于缓冲单元指针，生产者进程每次将产品放入该指针指示的缓冲单元，并将指针后移一个缓冲单元unsigned short out = 0; /相当于缓冲单元指针，消费者进程每次从该指针指示的缓冲单元取出产品，并将指针后移一个缓冲单元typedef struct BufferTypeint productID;int state; /0表示缓冲单元空，表示缓冲单元满（有产品）Buffer;Buffer g_bufferSIZE_OF_BUFFER; /缓冲队列（作为循环队列使用）bool g_continue = true; /控制程序结束HANDLE g_hMutex; /线程间互斥的信号量HANDLE g_hEmptySemaphore; /线程间同步的信号量HANDLE g_hFullSemaphore; /线程间同步的信号量DWORD WINAPI Producer(LPVOID); /生产者线程DWORD WINAPI Consumer(LPVOID); /消费者线程int main() /创建互斥的信号量和同步的信号量 g_hMutex = CreateMutex(NULL,FALSE,NULL); g_hEmptySemaphore = CreateSemaphore(NULL,SIZE_OF_BUFFER,SIZE_OF_BUFFER,NULL); g_hFullSemaphore = CreateSemaphore(NULL,0,SIZE_OF_BUFFER,NULL); /调整下面的数值，可以发现，当生产者个数多于消费者个数时，生产速度快，生产者经常等待消费者；反之，消费者经常等待 const unsigned short PRODUCERS_COUNT = 3; /要创建的生产者线程的个数 const unsigned short CONSUMERS_COUNT = 1; /要创建的消费者线程的个数 /总的线程数 const unsigned short THREADS_COUNT = PRODUCERS_COUNT+CONSUMERS_COUNT;HANDLE hProducerThreadPRODUCERS_COUNT;/生产者线程的handleHANDLE hConsumerThreadCONSUMERS_COUNT;/消费者线程的handle DWORD producerIDPRODUCERS_COUNT; /生产者线程ID DWORD consumerIDCONSUMERS_COUNT; /消费者线程IDint i; /创建生产者线程 for (i=0;iPRODUCERS_COUNT;+i) hProducerThreadi=CreateThread(NULL,0,Producer,NULL,0,&producerIDi); if (hProducerThreadi=NULL) return -1; /创建消费者线程 for (i=0;iCONSUMERS_COUNT;+i) hConsumerThreadi=CreateThread(NULL,0,Consumer,NULL,0,&consumerIDi); if (hConsumerThreadi=NULL) return -1; if(getchar() /按回车后终止程序运行g_continue = false; return 0;/生产者把新生产的产品放入缓冲区void AddToBuffer()ProductID+; /生产者生产出产品号 g_ductID = ProductID;/将产品放入缓冲单元g_bufferin.state=1;/置“满”标志 /输出缓冲队列当前的状态coutn生产者将产品ProductID 放入缓冲单元in ，缓冲队列当前状态为：endl;cout缓冲单元编号 产品编号 缓冲单元状态endl; for (int i=0;iSIZE_OF_BUFFER;i+)cout i g_ductID g_bufferi.stateendl; in = (in+1)%SIZE_OF_BUFFER;/更新指针，使其指向生产者下一次需要操作的缓冲单元/从缓冲区中取出一个产品void TakeFromBuffer() ConsumeID = g_ductID;/从缓冲队列中取出一个产品g_ductID=0;/删除该缓冲单元内容g_bufferout.state=0;/置“空”标识 /输出缓冲队列当前的状态coutn消费者从缓冲单元out 将产品ConsumeID 取出，缓冲队列当前状态为：endl;cout缓冲单元编号 产品编号 缓冲单元状态endl; for (int i=0;iSIZE_OF_BUFFER;i+)cout i g_ductID g_bufferi.stateendl; out = (out+1)%SIZE_OF_BUFFER;/更新指针，使其指向消费者下一次需要操作的缓冲单元/生产者DWORD WINAPI Producer(LPVOID lpPara) while(g_continue) WaitForSingleObject(g_hEmptySemaphore,INFINITE); WaitForSingleObject(g_hMutex,INFINITE); AddToBuffer();Sleep(200); ReleaseMutex(g_hMutex); ReleaseSemaphore(g_hFullSemaphore,1,NULL); return 0;/消费者DWORD WINAPI Consumer(LPVOID lpPara) while(g_continue) WaitForSingleObject(g_hFullSemaphore,INFINITE); Wait