生產(chǎn)者與消費(fèi)者問題(附源碼)(共7頁)

《生產(chǎn)者與消費(fèi)者問題(附源碼)(共7頁)》由會(huì)員分享，可在線閱讀，更多相關(guān)《生產(chǎn)者與消費(fèi)者問題(附源碼)(共7頁)（7頁珍藏版）》請?jiān)谘b配圖網(wǎng)上搜索。

1、精選優(yōu)質(zhì)文檔-傾情為你奉上操作系統(tǒng)實(shí)驗(yàn)報(bào)告專業(yè) 網(wǎng)絡(luò)工程 班級 08102 學(xué)號 姓名 課程名稱操作系統(tǒng) 學(xué)年 20102011 學(xué)期 下課程類別專業(yè)必修 限選任選實(shí)踐實(shí)驗(yàn)時(shí)間 2010年11月3日實(shí)驗(yàn)名稱實(shí)驗(yàn)一：生產(chǎn)者與消費(fèi)者問題實(shí)驗(yàn)?zāi)康暮鸵笕胬斫馍a(chǎn)者與消費(fèi)者問題模型，掌握解決該問題的算法思想，正確使用同步機(jī)制。實(shí)驗(yàn)軟硬件要求Pentium | 450以上 CPU 64MB以上 內(nèi)存WINDOWS XP Visual C+6.0實(shí)驗(yàn)內(nèi)容、方法和步驟（可附頁）問題描述：一組生產(chǎn)者向一組消費(fèi)者提供商品，共享一個(gè)有界緩沖池，生產(chǎn)者向其中放入商品，消費(fèi)者從中取得商品。假定這些生產(chǎn)者和消費(fèi)者互相

2、等效，只要緩沖池未滿，生產(chǎn)者可將商品送入緩沖池；只要緩沖池未空，消費(fèi)者可從緩沖池取走一商品。功能要求：根據(jù)進(jìn)程同步機(jī)制，編寫一個(gè)解決上述問題的程序，可顯示緩沖池狀態(tài)、放商品、取商品等過程。具體參數(shù)：3個(gè)生產(chǎn)者進(jìn)程，2個(gè)消費(fèi)者進(jìn)程； 緩沖區(qū)單元個(gè)數(shù)N=4；在本程序中是緩沖區(qū)中的數(shù)從0變?yōu)?表示模擬生產(chǎn)一個(gè)產(chǎn)品，消費(fèi)時(shí)則將對應(yīng)緩沖區(qū)內(nèi)的1變?yōu)?，為模擬消費(fèi)一個(gè)產(chǎn)品。實(shí)驗(yàn)結(jié)果（可附頁）見截圖小結(jié)這次多線程的操作系統(tǒng)實(shí)驗(yàn)，使我對線程的概念以及多線程程序中線程間的運(yùn)行有了更深的認(rèn)識，同時(shí)也讓我的編程能力得到了一定的提高。這次做的用多線程實(shí)現(xiàn)生產(chǎn)者與消費(fèi)者模型的實(shí)驗(yàn)，由于我的編程能力基礎(chǔ)比較差，對線程也是

3、一無所知，所以一開始覺得無從下手，但幸好老師給了充足的時(shí)間，我通過看網(wǎng)上找的視頻資料以及請教同學(xué)才漸漸地有了一點(diǎn)概念，然后我試著從網(wǎng)上下了一些多線程的程序分析里面的語句，基本弄懂了多線程的原理。評定成績：批閱教師： 年月日 一、問題概述三個(gè)生產(chǎn)者向兩個(gè)消費(fèi)者提供消息，它們共享一個(gè)有界緩沖池，緩沖池有四個(gè)緩沖區(qū)，生產(chǎn)者向其中投放消息，消費(fèi)者從中取得消息。假定這些生產(chǎn)者和消費(fèi)者互相等效，只要緩沖池未滿，生產(chǎn)者可將消息送入緩沖池；只要緩沖池未空，消費(fèi)者可從緩沖池取走一個(gè)消息。每個(gè)緩沖設(shè)有一個(gè)所標(biāo)記，生產(chǎn)者在生產(chǎn)產(chǎn)品以前要先判斷緩沖區(qū)是否已上鎖，消費(fèi)者在消費(fèi)產(chǎn)品之前也要進(jìn)行判斷。二、 設(shè)計(jì)流程圖主要流

4、程： 1、 生產(chǎn)者進(jìn)程生產(chǎn)流程圖，如圖1所示開 始是該緩沖區(qū)是否已上鎖？是否有空緩沖區(qū)？否是對該緩沖區(qū)上鎖模擬生產(chǎn)解 鎖結(jié) 束阻 塞否圖1 生產(chǎn)者進(jìn)程生產(chǎn)流程圖2、 消費(fèi)者進(jìn)程消費(fèi)流程圖，如圖2所示開 始是該緩沖區(qū)是否已上鎖？是否有滿緩沖區(qū)？否是對該緩沖區(qū)上鎖模擬消費(fèi)解 鎖結(jié) 束阻 塞否圖2 消費(fèi)者進(jìn)程消費(fèi)流程圖三、數(shù)據(jù)定義bool lock4=false,false,false,false;/四把鎖，分別對四個(gè)緩沖區(qū)進(jìn)行控制int buffer4=0,0,0,0;/緩沖區(qū)個(gè)數(shù)為44、 源程序1、生產(chǎn)者生產(chǎn)進(jìn)程函數(shù)DWORD WINAPI Producer(LPVOID lpParameter

5、)while(true)for(int j=0;j4;j+)if(bufferj=0)/找到空緩沖區(qū)if(lockj=false)/同步鎖為false，可以進(jìn)行操作lockj=true;/加鎖，防止其他線程操作此緩沖區(qū)if(bufferj1)/限定一個(gè)緩沖區(qū)只能存放一個(gè)資源+bufferj;/模擬生產(chǎn)資源cout生產(chǎn)一個(gè)資源，放入緩沖區(qū)j中endl;lockj=false;/解鎖break;/一次生產(chǎn)一個(gè)if(j=3)cout找不到空緩沖區(qū)，等待中。endl;Sleep(2000);return 0;2、消費(fèi)者消費(fèi)進(jìn)程函數(shù)DWORD WINAPI Customer(LPVOID lpParam

6、eter)while(true)for(int n=0;n=1)-buffern;/模擬消費(fèi)資源cout消費(fèi)一個(gè)資源，從緩沖區(qū)n中取出endl;lockn=false;/解鎖break;/一次生產(chǎn)一個(gè)if(n=3) cout找不到滿緩沖區(qū)，等待中。endl; Sleep(2000);3、主函數(shù)，創(chuàng)建5個(gè)進(jìn)程，其中3個(gè)生產(chǎn)者進(jìn)程，2個(gè)消費(fèi)者進(jìn)程int main(int argc,char* argv) HANDLE handle3;DWORD dw1,dw2,dw3,dw4,dw5;/創(chuàng)建5個(gè)進(jìn)程 handle0=CreateThread(NULL,0,Producer,NULL,0,&dw1)

7、; handle1=CreateThread(NULL,0,Producer,NULL,0,&dw2); handle2=CreateThread(NULL,0,Producer,NULL,0,&dw3); handle3=CreateThread(NULL,0,Customer,NULL,0,&dw4); handle4=CreateThread(NULL,0,Customer,NULL,0,&dw5);5、 運(yùn)行結(jié)果3個(gè)生產(chǎn)者2個(gè)消費(fèi)者，共享4個(gè)緩沖區(qū)，運(yùn)行結(jié)果如下：1、一個(gè)生產(chǎn)者生產(chǎn)，一個(gè)消費(fèi)者消費(fèi)：2、 兩個(gè)生產(chǎn)者連續(xù)生產(chǎn)，兩個(gè)消費(fèi)者連續(xù)消費(fèi)：3、 多個(gè)生產(chǎn)者于多個(gè)消費(fèi)者進(jìn)行生產(chǎn)消費(fèi)操

8、作：附:#include iostream.h#include windows.h#include stdio.hbool lock4=false,false,false,false;/四把鎖，分別對四個(gè)緩沖區(qū)進(jìn)行同步int buffer4=0,0,0,0;/緩沖區(qū)，表示資源的個(gè)數(shù)void display() cout-endl; cout緩沖區(qū) 0 1 2 3endl; for(int i=0;i4;i+)cout bufferi ; coutendl;DWORD WINAPI Producer(LPVOID lpParameter)while(true)for(int j=0;j4;j+)

9、if(bufferj=0)/找到空緩沖區(qū)if(lockj=false)/同步鎖為false，可以進(jìn)行操作lockj=true;/加鎖，防止其他線程操作此緩沖區(qū)if(bufferj1)/限定一個(gè)緩沖區(qū)只能存放一個(gè)資源+bufferj;/模擬生產(chǎn)資源cout生產(chǎn)一個(gè)資源，放入緩沖區(qū)j中endl;lockj=false;/解鎖break;/一次生產(chǎn)一個(gè)if(j=3)cout找不到空緩沖區(qū)，等待中。endl;Sleep(2000);return 0;DWORD WINAPI Customer(LPVOID lpParameter)while(true)for(int n=0;n=1)-buffern;

10、/模擬消費(fèi)資源cout消費(fèi)一個(gè)資源，從緩沖區(qū)n中取出endl;lockn=false;/解鎖break;/一次生產(chǎn)一個(gè)if(n=3) cout找不到滿緩沖區(qū)，等待中。endl; Sleep(2000);return 0;int main(int argc,char* argv) display();HANDLE handle3;DWORD dw1,dw2,dw3,dw4,dw0; handle0=CreateThread(NULL,0,Producer,NULL,0,&dw1); handle1=CreateThread(NULL,0,Producer,NULL,0,&dw2); handle2=CreateThread(NULL,0,Producer,NULL,0,&dw3); handle3=CreateThread(NULL,0,Customer,NULL,0,&dw4); handle4=CreateThread(NULL,0,Customer,NULL,0,&dw0); display(); Sleep(3000); display(); return 0;專心-專注-專業(yè)