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

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

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

3、一無(wú)所知，所以一開(kāi)始覺(jué)得無(wú)從下手，但幸好老師給了充足的時(shí)間，我通過(guò)看網(wǎng)上找的視頻資料以及請(qǐng)教同學(xué)才漸漸地有了一點(diǎn)概念，然后我試著從網(wǎng)上下了一些多線程的程序分析里面的語(yǔ)句，基本弄懂了多線程的原理。評(píng)定成績(jī)：批閱教師： 年月日 一、問(wèn)題概述三個(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所示開(kāi) 始是該緩沖區(qū)是否已上鎖？是否有空緩沖區(qū)？否是對(duì)該緩沖區(qū)上鎖模擬生產(chǎn)解 鎖結(jié) 束阻 塞否圖1 生產(chǎn)者進(jìn)程生產(chǎn)流程圖2、 消費(fèi)者進(jìn)程消費(fèi)流程圖，如圖2所示開(kāi) 始是該緩沖區(qū)是否已上鎖？是否有滿緩沖區(qū)？否是對(duì)該緩沖區(qū)上鎖模擬消費(fèi)解 鎖結(jié) 束阻 塞否圖2 消費(fèi)者進(jìn)程消費(fèi)流程圖三、數(shù)據(jù)定義bool lock4=false,false,false,false;/四把鎖，分別對(duì)四個(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;j<4;j+)if(bufferj=0)/找到空緩沖區(qū)if(lockj=false)/同步鎖為false，可以進(jìn)行操作lockj=true;/加鎖，防止其他線程操作此緩沖區(qū)if(bufferj<1)/限定一個(gè)緩沖區(qū)只能存放一個(gè)資源+bufferj;/模擬生產(chǎn)資源cout<<"生產(chǎn)一個(gè)資源，放入緩沖區(qū)"<<j<<"中"<<endl;lockj=false;/解鎖break;/一次生產(chǎn)一個(gè)if(j=3)cout<<"找不到空緩沖區(qū)

6、，等待中。"<<endl;Sleep(2000);return 0;2、消費(fèi)者消費(fèi)進(jìn)程函數(shù)DWORD WINAPI Customer(LPVOID lpParameter)while(true)for(int n=0;n<4;n+)if(buffern=1)/找到滿緩沖區(qū)if(lockn=false)/同步鎖為false，可以進(jìn)行操作lockn=true;/加鎖，防止其他線程操作此緩沖區(qū)if(buffern>=1)-buffern;/模擬消費(fèi)資源cout<<"消費(fèi)一個(gè)資源，從緩沖區(qū)"<<n<<"

7、中取出"<<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); handle1=CreateTh

8、read(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)操作：

9、附:#include "iostream.h"#include "windows.h"#include "stdio.h"bool lock4=false,false,false,false;/四把鎖，分別對(duì)四個(gè)緩沖區(qū)進(jìn)行同步int buffer4=0,0,0,0;/緩沖區(qū)，表示資源的個(gè)數(shù)void display() cout<<"-"<<endl; cout<<"緩沖區(qū) 0 1 2 3"<<endl; for(int i=0;i<4;i+)

10、cout<<" "<<bufferi<<" " cout<<endl;DWORD WINAPI Producer(LPVOID lpParameter)while(true)for(int j=0;j<4;j+)if(bufferj=0)/找到空緩沖區(qū)if(lockj=false)/同步鎖為false，可以進(jìn)行操作lockj=true;/加鎖，防止其他線程操作此緩沖區(qū)if(bufferj<1)/限定一個(gè)緩沖區(qū)只能存放一個(gè)資源+bufferj;/模擬生產(chǎn)資源cout<<"生產(chǎn)

11、一個(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<4;n+)if(buffern=1)/找到滿緩沖區(qū)if(lockn=false)/同步鎖為false，可以進(jìn)行操作lockn=true

12、;/加鎖，防止其他線程操作此緩沖區(qū)if(buffern>=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);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