1实验1：生产者消费者问题

1、福建农林大学金山学院实验报告系（教研室）：专业:计算机科学与技术年级:实验课程:生产者与消费者实验 姓名:学号:实验室号:1#608计算机号:实验时间:指导教师签字:成绩:实验1：生产者消费者问题实验目的生产者消费者问题是操作系统中经典的同步和互斥问题。通过实验，要求学生掌握两者之间的同步信号量和互斥信号量的使用，更深刻了解临界资源、同步和互斥的概念。实验要求1. 一组生产者通过一个具有N个缓冲区的缓冲池循环不断地向一组消费者提供产品。2. 建一个队列，队列的长度由n记录，定义两个指针，分别指向队列的头和尾消费者从头指针读取数据，每读取一个数据把 n-，生产者把数据写入尾指针，每写 入一个数据

2、就n+，当n=N的时候生产者暂停写入数据。3.注意：缓冲池队列，用互斥锁保护。实验内容和原理1. 分别画出生产者和消费者的流程图否否2. 针对生产者和消费者问题，可以分为哪几种情况，使用了哪些原语？分别代表 什么意思？过程如何？阐述哪些进程之间存在同步，哪些进程之间存在互斥。3. 缓冲区是否为临界资源？是否可以循环使用？通过什么来实现？举例说明（可 画图）四、实验环境1. 硬件：PC机；2. 软件：Windows操作系统、VC6.0。五、算法描述及实验步骤#in elude #in elude const un sig ned short SIZE_OF_BUFFER = 10; un sig

3、 ned short P roductID = 0;un sig ned short Con sumeID = 0;unsigned short in = 0; unsigned short out = 0;int g_bufferSIZE_OF_BUFFER; bool g_continue = true; HANDLE g_hMutex;HANDLE g_hFullSemaphore; HANDLE g_hEmptySemaphore;DWORD WINAPI Producer(LPVOID);DWORD WINAPI Consumer(LPVOID);int main() g_hMute

4、x = CreateMutex(NULL,FALSE,NULL); g_hFullSemaphoreCreateSemaphore(NULL,SIZE_OF_BUFFER-1,SIZE_OF_BUFFER-1,NULL); g_hEmptySemaphore = CreateSemaphore(NULL,0,SIZE_OF_BUFFER-1,NULL);THREADS_COUNTconst unsigned short PRODUCERS_COUNT = 3; const unsigned short CONSUMERS_COUNT = 1; const unsigned short PROD

5、UCERS_COUNT+CONSUMERS_COUNT;HANDLE hThreadsPRODUCERS_COUNT;DWORD producerIDCONSUMERS_COUNT;DWORD consumerIDTHREADS_COUNT;for (int i=0;iPRODUCERS_COUNT;+i) hThreadsi=CreateThread(NULL,0,Producer,NULL,0,&producerIDi); if (hThreadsi=NULL) return -1;for ( i=0;iCONSUMERS_COUNT;+i) hThreadsPRODUCERS_COUNT

6、+i=CreateThread(NULL,0,Consumer,NULL,0,&consum erIDi);if (hThreadsi=NULL) return -1;while(g_continue)if(getchar() / 按回车后终止程序运行 g_continue = false;return 0;void Produce() std:cerr Producing +ProductID . ; std:cerr Succeed std:endl;void Append() std:cerr Appending a product . ; g_bufferin = ProductID;

7、in = (in+1)%SIZE_OF_BUFFER; std:cerr Succeed std:endl;for (int i=0;iSIZE_OF_BUFFER;+i) std:cout i : g_bufferi; if (i=in) std:cout -生产;if (i=out) std:cout -消费 ;std:cout std:endl;void Take() std:cerr Taking a product . ; ConsumeID = g_bufferout; out = (out+1)%SIZE_OF_BUFFER; std:cerr Succeed std:endl;

8、g_bufferi; 生产 ; 消费 ; for (int i=0;iSIZE_OF_BUFFER;+i) std:cout i : if (i=in) std:cout -if (i=out) std:cout - std:cout std:endl;void Consume() std:cerr Consuming ConsumeID . ; std:cerr Succeed std:endl;DWORD WINAPI Producer(LPVOID lpPara) while(g_continue)WaitForSingleObject(g_hFullSemaphore,INFINITE

9、); WaitForSingleObject(g_hMutex,INFINITE); Produce();Appen d();Slee p(1500);ReleaseMutex(g_hMutex);ReleaseSema phore(g_hE mp tySema phore,1,NULL); return 0;DWORDWINA PI Co nsumer(L PVOID IpPara) while(g_c ontinu e)WaitForSi ngleObject(g_hE mp tySema phore,INFINITE); WaitForSi ngleObject(g_hMutex,INF

10、INITE);Take();Con sume();Slee p(1500);ReleaseMutex(g_hMutex);ReleaseSema phore(g_hFullSema phore,1,NULL);return 0;六、调试过程Compiling.KcppD:116788: D;1167eW 购 cl.exe程序有错误:-ConFiguration: 1 - Uir32 DMug:error C21J16: syntax 时“r : iiiHingMF叶p identifier RpM詰吐乩即血牝M.cppOH) : error C21W:刊n皿 error : nissing *;* before Jkohj - 1 errDr(s)p fl varnirg(5)在94和108行分别少了两个封号。 经改正后无错误如图所示：ConFiguratLon: 1 - Uin32 DbugConplling. 1 -cpp 1,Qbj - B errDr(5), Q uarningfs)七、实验结果Producing Z Appending a n： i：2 =3：g *D: 1 167Q8O44|EiiLl1 - exe Succeedproduct .,* Succeed1 消费2B 生产B7 =8：7： Producing 3 ._ Succeed hppen