操作系統(tǒng)實驗-多線程同步

一、實驗?zāi)康暮蛢?nèi)容1、實驗?zāi)康脑谡莆栈谙⒌膚indows程序結(jié)構(gòu)和多線程程序設(shè)計方法的基礎(chǔ)上，設(shè)計一個多線程同步的程序。使學生能夠從程序設(shè)計的角度了解多線程程序設(shè)計的方法和在windows系統(tǒng)下多線程同步互斥的機制。2、實驗內(nèi)容理解Windows程序設(shè)計的基本思想，理解基于消息的程序設(shè)計方法，能夠設(shè)計出簡單的基于事件的windows程序，完成基本控件的使用結(jié)合操作系統(tǒng)中信號量與互斥體的概念，在MFC中找到對應(yīng)的相關(guān)類。設(shè)計一個多線程同步的程序。二、實驗方案1、定義相關(guān)的信息，創(chuàng)建生產(chǎn)者和消費者線程。設(shè)定生產(chǎn)和消費的規(guī)則，初步設(shè)定沒生產(chǎn)兩個產(chǎn)品就將其中一個取出消費。2、設(shè)定一個循環(huán)隊列，作為緩沖區(qū)，設(shè)計生產(chǎn)者消費者算法。3、使用互斥的思路，當緩沖區(qū)滿時迫使生產(chǎn)者等待，當緩沖區(qū)空時迫使消費者等待。4、源代碼#include<windows.h>#include<iostream>usingnamespacestd;unsignedshortProductID=0,ConsumeID=0,in=0,out=0;constunsignedshortSIZE_OF_BUFFER=10;//緩沖區(qū)長度intg_buffer[SIZE_OF_BUFFER];//緩沖區(qū)是個循環(huán)隊列boolg_continue=true;//控制程序結(jié)束HANDLEg_hMutex;//用于線程間的互斥HANDLEg_hFullSemaphore;HANDLEg_hEmptySemaphore;DWORDWINAPIProducer(LPVOID);//生產(chǎn)者線程DWORDWINAPIConsumer(LPVOID);//消費者線程constunsignedshortPRODUCERS_COUNT=2;//生產(chǎn)者的個數(shù)constunsignedshortCONSUMERS_COUNT=1;//消費者的個數(shù)constunsignedshortTHREADS_COUNT=PRODUCERS_COUNT+CONSUMERS_COUNT;HANDLEhThreads[PRODUCERS_COUNT];//各線程的handleDWORDproducerID[CONSUMERS_COUNT];//生產(chǎn)者線程的標識符DWORDconsumerID[THREADS_COUNT];//消費者線程的標識符voidProduce(){cout<<"正在生產(chǎn)第”<<++ProductID<<”號產(chǎn)品cout<<"生產(chǎn)成功"<<endl;}voidAppend(){cout<<”存放新產(chǎn)品";g_buffer[in]=ProductID;in=(in+1)%SIZE_OF_BUFFER;cout<<"成功”<<endl;cout<<”緩沖區(qū)情況"<<endl;for(inti=O;i<SIZE_OF_BUFFER;++i){cout<<i<<":"<<g_buffer[i];if(i==in)cout<<"<--生產(chǎn)"；if(i==out)cout<<"<--消費"；cout<<endl;}cout<<endl;}voidTake(){cout<<"取出一個產(chǎn)品";ConsumeID=g_buffer[out];out=(out+1)%SIZE_OF_BUFFER;cout<<"成功"<<endl;for(inti=O;i<SIZE_OF_BUFFER;++i){cout<<i<<":"<<g_buffer[i];if(i==in)cout<<"<--生產(chǎn)"；if(i==out)cout<<"<--消費"；cout<<endl;}cout<<endl;}voidConsume(){cout<<"消費第"<<ConsumeID<<"號產(chǎn)品"；cout<<"成功"<<endl;}DWORDWINAPIProducer(LPVOIDlpPara){while(g_continue){WaitForSingleObject(g_hFullSemaphore,INFINITE);WaitForSingleObject(g_hMutex,INFINITE);Produce();

Append();Sleep(1500);ReleaseMutex(g_hMutex);ReleaseSemaphore(g_hEmptySemaphore,1,NULL);}return0;}DWORDWINAPIConsumer(LPVOIDlpPara){while(g_continue){WaitForSingleObject(g_hEmptySemaphore,INFINITE);WaitForSingleObject(g_hMutex,INFINITE);Take();Consume();Sleep(2000);ReleaseMutex(g_hMutex);ReleaseSemaphore(g_hFullSemaphore,1,NULL);}return0;}intmain(){〃創(chuàng)建各個互斥信號g_hMutex=CreateMutex(NULL,FALSE,NULL);g_hFullSemaphore=CreateSemaphore(NULL,SIZE_OF_BUFFER-1,SIZE_OF_BUFFER-1,NULL);g_hEmptySemaphore=CreateSemaphore(NULL,0,SIZE_OF_BUFFER-1,NULL);//創(chuàng)建生產(chǎn)者線程for(inti=0;i<PRODUCERS_COUNT;++i){hThreads[i]=CreateThread(NULL,0,Producer,NULL,0,&producerID[i]);if(hThreads[i]二二NULL)return-1;}//創(chuàng)建消費者線程for(i=0;i<CONSUMERS_COUNT;++i){hThreads[PRODUCERS_COUNT+i]=CreateThread(NULL,0,Consumer,NULL,0,&consumerID[i]);if(hThreads[i]==NULL){return-1;}while(g_continue){if(getchar()){g_continue={g_continue=false;}//按回車后終止程序運行return0;}}三、實驗數(shù)據(jù)、結(jié)果分析運行結(jié)果應(yīng)X:\DOCUMENISANDSETT1