实验三生产者与消费者

实验三：生产者与花费者一、实验目的学习和掌握操作系统中进度之间的通讯；理解和掌握使用信号量体制来是想进度之间的同步和互斥；学习使用创立文件对象，并利用文件映照对象来实现数据通讯。二、实验内容?一个大小为6的缓冲区，初始为空，每个缓冲区能寄存一个长度若为10个字符的字符串。2个生产者–随机等候一段时间，往缓冲区增添数据，–若缓冲区已满，等候花费者取走数据后再增添–重复12次3个花费者–随机等候一段时间，从缓冲区读取数据–若缓冲区为空，等候生产者增添数据后再读取–重复8次说明：显示每次增添和读取数据的时间及缓冲区的状态生产者和花费者用进度模拟，缓冲区用共享内存来实现三、实验环境1.Windows下：Windows8,Visualstudio20132.Linux下：LinuxUbuntu4，gcc四、程序设计与实现Windows下：A．主要函数说明：（1）PROCESS_INFORMATIONStartClone(intnCloneID)功能：用来创立5个同样的进度，前两个为生产者，后三两个为花费者，给予其不一样的ID值，返回进度的信息。（2）CreateSemaphore（）；功能：创立3个信号量：full，empty，mutex。来互斥的接见缓冲区，实现通讯。（3）CreateFileMapping（）功能：在目前运转的进度中创立文件映照对象，来模拟共享缓冲区MapViewOfFile（）功能：在此文件映照上创立视图映照到目前应用程序的地点空间B．程序流程图开始初始化:创立的子进度个数为0nClone=0;创立5个同样的子进度nClone++2<nClone<6申请缓冲区0<nClone<3申请缓冲区nClone=P(full)P(empty)P(mutex)P(mutex)0把产品放入缓冲从缓冲区取产创立3个信号量：品：将1置为0区：将0置为1full,empty,mutex开释缓冲区：开释缓冲区：V(mutex)V(mutex)V(full)创立共享内存V(empty)N

N随机等候随机等候等候子进度履行完成12次放YY12次取完了完了结束每个子进度结束实验代码以下：Windows：:定义控制台应用程序的进口点。n");hMutexMapping=CreateMutex(NULL,true,"mutex");HANDLEhMapping=CreateFileMapping(NULL,NULL,PAGE_READWRITE,0,sizeof(LONG),"map");if(hMapping!=INVALID_HANDLE_VALUE){LPVOIDpData=MapViewOfFile(hMapping,FILE_MAP_ALL_ACCESS,0,0,0);if(pData!=NULL){ZeroMemory(pData,sizeof(LONG));}structbuf*pnData=reinterpret_cast<structbuf*>(pData);pnData->read=0;pnData->write=0;pnData->num=0;memset(pnData->buffer,0,sizeof(pnData->buffer));UnmapViewOfFile(pData);}CreateSemaphore(NULL,3,3,"EMPTY");CreateSemaphore(NULL,0,3,"FULL");BOOLbCreateOK=StartClone();if(!bCreateOK){n");}else{n");}ReleaseMutex(hMutexMapping);}voidProductor(intn){intj;printf("Productorisrunning.\n");hMutexMapping=OpenMutex(MUTEX_ALL_ACCESS,true,"mutex");HANDLEhMapping=OpenFileMapping(FILE_MAP_ALL_ACCESS,NULL,"map");if(hMapping==INVALID_HANDLE_VALUE){printf("error\n");}HANDLEsemEmpty=OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"EMPTY");HANDLEsemFull=OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"FULL");for(inti=0;i<6;i++){WaitForSingleObject(semEmpty,INFINITE);SYSTEMTIMEst;GetSystemTime(&st);srand((unsigned)time(0));Sleep(rand()/6);WaitForSingleObject(hMutexMapping,INFINITE);LPVOIDpFile=MapViewOfFile(hMapping,FILE_MAP_ALL_ACCESS,0,0,0);if(pFile!=NULL){structbuf*pnData=reinterpret_cast<structbuf*>(pFile);pnData->buffer[pnData->write]=1;pnData->write=(pnData->write+1)%3;pnData->num++;printf("%02d:%02d:%02d生产者[%d]生产成功缓冲区中节余%d个",,,,n,pnData->num);for(j=0;j<3;j++){printf("%d",pnData->buffer[j]);}printf("\n");}UnmapViewOfFile(pFile);pFile=NULL;ReleaseSemaphore(semFull,1,NULL);ReleaseMutex(hMutexMapping);}printf("生产者[%d]生产完成\n",n);}voidConsumer(intn){intj;printf("Consumerisrunning.\n");hMutexMapping=OpenMutex(MUTEX_ALL_ACCESS,true,"mutex");HANDLEhMapping=OpenFileMapping(FILE_MAP_ALL_ACCESS,NULL,"map");if(hMapping==INVALID_HANDLE_VALUE){printf("error\n");}HANDLEsemEmpty=OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"EMPTY");HANDLEsemFull=OpenSemaphore(SEMAPHORE_ALL_ACCESS,FALSE,"FULL");for(inti=0;i<4;i++){WaitForSingleObject(semFull,INFINITE);SYSTEMTIMEst;GetSystemTime(&st);srand((unsigned)time(0));Sleep(rand()/6);WaitForSingleObject(hMutexMapping,INFINITE);LPVOIDpFile=MapViewOfFile(hMapping,FILE_MAP_ALL_ACCESS,0,0,0);if(pFile!=NULL){structbuf*pnData=reinterpret_cast<structbuf*>(pFile);pnData->buffer[pnData->read]=0;pnData->read=(pnData->read+1)%3;pnData->num--;printf("%02d:%02d:%02d花费者[%d]花费成功缓冲区中节余%d个",,,,n,pnData->num);for(j=0;j<3;j++){printf("%d",pnData->buffer[j]);}printf("\n");}UnmapViewOfFile(pFile);pFile=NULL;ReleaseSemaphore(semEmpty,1,NULL);ReleaseMutex(hMutexMapping);}printf("花费者[%d]花费完成\n",n);}intmain(intargc,char**argv){if(argc>1&&strcmp(argv[1],"productor")==0){Productor(atoi(argv[2]));}elseif(argc>1&&strcmp(argv[1],"consumer")==0){Consumer(atoi(argv[2]));}else{Parent();WaitForMultipleObjects(num,lpHandle,

true,INFINITE);}return0;}Linux下代码：;exit(1);}sputproduct%ld:%ld",argv[0],,;printf("Nowthebufferis");for(j=1;j<=3;j++)printf("%4d",(out+j)->buf);printf("\n");v(sem_id,SEM_MUTEX);sgetproduct%ld:%ld",argv[0],,;