實(shí)驗(yàn)三生產(chǎn)者與消費(fèi)者

實(shí)驗(yàn)三：生產(chǎn)者與花費(fèi)者一、實(shí)驗(yàn)?zāi)康膶W(xué)習(xí)和掌握操作系統(tǒng)中進(jìn)度之間的通訊；理解和掌握使用信號(hào)量體制來(lái)是想進(jìn)度之間的同步和互斥；學(xué)習(xí)使用創(chuàng)立文件對(duì)象，并利用文件映照對(duì)象來(lái)實(shí)現(xiàn)數(shù)據(jù)通訊。二、實(shí)驗(yàn)內(nèi)容?一個(gè)大小為6的緩沖區(qū)，初始為空，每個(gè)緩沖區(qū)能寄存一個(gè)長(zhǎng)度若為10個(gè)字符的字符串。2個(gè)生產(chǎn)者–隨機(jī)等候一段時(shí)間，往緩沖區(qū)增添數(shù)據(jù)，–若緩沖區(qū)已滿，等候花費(fèi)者取走數(shù)據(jù)后再增添–重復(fù)12次3個(gè)花費(fèi)者–隨機(jī)等候一段時(shí)間，從緩沖區(qū)讀取數(shù)據(jù)–若緩沖區(qū)為空，等候生產(chǎn)者增添數(shù)據(jù)后再讀取–重復(fù)8次說(shuō)明：顯示每次增添和讀取數(shù)據(jù)的時(shí)間及緩沖區(qū)的狀態(tài)生產(chǎn)者和花費(fèi)者用進(jìn)度模擬，緩沖區(qū)用共享內(nèi)存來(lái)實(shí)現(xiàn)三、實(shí)驗(yàn)環(huán)境1.Windows下：Windows8,Visualstudio20132.Linux下：LinuxUbuntu4，gcc四、程序設(shè)計(jì)與實(shí)現(xiàn)Windows下：A．主要函數(shù)說(shuō)明：（1）PROCESS_INFORMATIONStartClone(intnCloneID)功能：用來(lái)創(chuàng)立5個(gè)同樣的進(jìn)度，前兩個(gè)為生產(chǎn)者，后三兩個(gè)為花費(fèi)者，給予其不一樣的ID值，返回進(jìn)度的信息。（2）CreateSemaphore（）；功能：創(chuàng)立3個(gè)信號(hào)量：full，empty，mutex。來(lái)互斥的接見(jiàn)緩沖區(qū)，實(shí)現(xiàn)通訊。（3）CreateFileMapping（）功能：在目前運(yùn)轉(zhuǎn)的進(jìn)度中創(chuàng)立文件映照對(duì)象，來(lái)模擬共享緩沖區(qū)MapViewOfFile（）功能：在此文件映照上創(chuàng)立視圖映照到目前應(yīng)用程序的地點(diǎn)空間B．程序流程圖開(kāi)始初始化:創(chuàng)立的子進(jìn)度個(gè)數(shù)為0nClone=0;創(chuàng)立5個(gè)同樣的子進(jìn)度nClone++2<nClone<6申請(qǐng)緩沖區(qū)0<nClone<3申請(qǐng)緩沖區(qū)nClone=P(full)P(empty)P(mutex)P(mutex)0把產(chǎn)品放入緩沖從緩沖區(qū)取產(chǎn)創(chuàng)立3個(gè)信號(hào)量：品：將1置為0區(qū)：將0置為1full,empty,mutex開(kāi)釋緩沖區(qū)：開(kāi)釋緩沖區(qū)：V(mutex)V(mutex)V(full)創(chuàng)立共享內(nèi)存V(empty)N

N隨機(jī)等候隨機(jī)等候等候子進(jìn)度履行完成12次放YY12次取完了完了結(jié)束每個(gè)子進(jìn)度結(jié)束實(shí)驗(yàn)代碼以下：Windows：:定義控制臺(tái)應(yīng)用程序的進(jìn)口點(diǎn)。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生產(chǎn)者[%d]生產(chǎn)成功緩沖區(qū)中節(jié)余%d個(gè)",,,,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("生產(chǎn)者[%d]生產(chǎn)完成\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花費(fèi)者[%d]花費(fèi)成功緩沖區(qū)中節(jié)余%d個(gè)",,,,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("花費(fèi)者[%d]花費(fèi)完成\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],,;