生產(chǎn)者消費(fèi)者實(shí)驗(yàn)報(bào)告.答案

1、 南昌大學(xué)實(shí)驗(yàn)報(bào)告學(xué)生姓名： 倪煥 學(xué) 號(hào)： 8000114018 專業(yè)班級(jí)： 軟件工程141班 實(shí)驗(yàn)類型： 驗(yàn)證 綜合 設(shè)計(jì) 創(chuàng)新 實(shí)驗(yàn)日期： 2016.5.24 實(shí)驗(yàn)成績(jī)： 一、 實(shí)驗(yàn)項(xiàng)目名稱 哲學(xué)家就餐問題二、實(shí)驗(yàn)?zāi)康?利用pv操作解決生產(chǎn)者消費(fèi)者問題3、 軟硬件環(huán)境 軟件：visual studio2010 硬件：pc機(jī)一臺(tái)4、 實(shí)驗(yàn)內(nèi)容結(jié)果一、實(shí)現(xiàn)代碼 3個(gè)生產(chǎn)者1個(gè)消費(fèi)者 ，生產(chǎn)者會(huì)等待消費(fèi)者#include <windows.h>#include <iostream>const unsigned short size_of_buffer = 10; /緩沖

2、區(qū)長(zhǎng)度unsigned short productid = 0; /產(chǎn)品號(hào)unsigned short consumeid = 0; /將被消耗的產(chǎn)品號(hào)unsigned short in = 0; /產(chǎn)品進(jìn)緩沖區(qū)時(shí)的緩沖區(qū)下標(biāo)unsigned short out = 0; /產(chǎn)品出緩沖區(qū)時(shí)的緩沖區(qū)下標(biāo)int g_buffersize_of_buffer; /緩沖區(qū)是個(gè)循環(huán)隊(duì)列bool g_continue = true; /控制程序結(jié)束handle g_hmutex; /用于線程間的互斥handle g_hfullsemaphore; /當(dāng)緩沖區(qū)滿時(shí)迫使生產(chǎn)者等待handle g_hempty

3、semaphore; /當(dāng)緩沖區(qū)空時(shí)迫使消費(fèi)者等待dword winapi producer(lpvoid); /生產(chǎn)者線程dword winapi consumer(lpvoid); /消費(fèi)者線程int main() /創(chuàng)建各個(gè)互斥信號(hào) 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-

4、1,null); /調(diào)整下面的數(shù)值，可以發(fā)現(xiàn)，當(dāng)生產(chǎn)者個(gè)數(shù)多于消費(fèi)者個(gè)數(shù)時(shí)， /生產(chǎn)速度快，生產(chǎn)者經(jīng)常等待消費(fèi)者；反之，消費(fèi)者經(jīng)常等待 const unsigned short producers_count = 3; /生產(chǎn)者的個(gè)數(shù) const unsigned short consumers_count = 1; /消費(fèi)者的個(gè)數(shù) /總的線程數(shù) const unsigned short threads_count = producers_count+consumers_count; handle hthreadsproducers_count; /各線程的handle dword produ

5、ceridconsumers_count; /生產(chǎn)者線程的標(biāo)識(shí)符 dword consumeridthreads_count; /消費(fèi)者線程的標(biāo)識(shí)符 /創(chuàng)建生產(chǎn)者線程 for (int i=0;i<producers_count;+i) hthreadsi=createthread(null,0,producer,null,0,&produceridi); if (hthreadsi=null) return -1; /創(chuàng)建消費(fèi)者線程 for (int i=0;i<consumers_count;+i) hthreadsproducers_count+i=createthr

6、ead(null,0,consumer,null,0,&consumeridi); if (hthreadsi=null) return -1; while(g_continue) if(getchar() /按回車后終止程序運(yùn)行 g_continue = false; return 0;/生產(chǎn)一個(gè)產(chǎn)品。簡(jiǎn)單模擬了一下，僅輸出新產(chǎn)品的id號(hào)void produce() std:cerr << "producing " << +productid << " . " std:cerr << "

7、succeed" << std:endl;/把新生產(chǎn)的產(chǎn)品放入緩沖區(qū)void append() std:cerr << "appending a product . " g_bufferin = productid; in = (in+1)%size_of_buffer; std:cerr << "succeed" << std:endl; /輸出緩沖區(qū)當(dāng)前的狀態(tài) for (int i=0;i<size_of_buffer;+i) std:cout << i <<&q

8、uot;: " << g_bufferi; if (i=in) std:cout << " <- 生產(chǎn)" if (i=out) std:cout << " <- 消費(fèi)" std:cout << std:endl; /從緩沖區(qū)中取出一個(gè)產(chǎn)品void take() std:cerr << "taking a product . " consumeid = g_bufferout; out = (out+1)%size_of_buffer; std:cerr

9、<< "succeed" << std:endl; /輸出緩沖區(qū)當(dāng)前的狀態(tài) for (int i=0;i<size_of_buffer;+i) std:cout << i <<": " << g_bufferi; if (i=in) std:cout << " <- 生產(chǎn)" if (i=out) std:cout << " <- 消費(fèi)" std:cout << std:endl; /消耗一個(gè)產(chǎn)品void

10、 consume() std:cerr << "consuming " << consumeid << " . " std:cerr << "succeed" << std:endl;/生產(chǎn)者dword winapi producer(lpvoid lppara) while(g_continue) waitforsingleobject(g_hfullsemaphore,infinite); waitforsingleobject(g_hmutex,infinite); p

11、roduce(); append(); sleep(1500); releasemutex(g_hmutex); releasesemaphore(g_hemptysemaphore,1,null); return 0;/消費(fèi)者dword winapi consumer(lpvoid lppara) while(g_continue) waitforsingleobject(g_hemptysemaphore,infinite); waitforsingleobject(g_hmutex,infinite); take(); consume(); sleep(1500); releasemut

12、ex(g_hmutex); releasesemaphore(g_hfullsemaphore,1,null); return 0; 二、實(shí)現(xiàn)代碼 一個(gè)生產(chǎn)者一個(gè)消費(fèi)者 /* 用信號(hào)量解決生產(chǎn)者消費(fèi)者問題 */ #include <stdio.h> #define n 10 typedef int semaphore; /* 信號(hào)量是一種特殊的整型變量 */ semaphore mutex=1; /* 互斥訪問 */ semaphore empty=n; /* 記錄緩沖區(qū)中空的槽數(shù) */ semaphore full=0; /* 記錄緩沖區(qū)中滿的槽數(shù)*/ semaphore buf

13、n; /* 有n個(gè)槽數(shù)的緩沖區(qū)bufn，并實(shí)現(xiàn)循環(huán)緩沖隊(duì)列 */ semaphore front=0, rear=0; void p(semaphore *x) /* p操作 */ *x=(*x)-1; void v(semaphore *y) /* v操作 */ *y=(*y)+1; void produce_item(int *item_ptr) /*printf("produce an itemn");*/ *item_ptr='m' /* 'm' is "man滿" */ void enter_item(int x

14、) front=(front+1)%n; buffront=x; printf("enter_item %c to buf%dn", buffront, front); void remove_item(int *yy) rear=(rear+1)%n; printf("remove_item %c from buf%d", bufrear, rear); *yy=bufrear; bufrear='k' /* 'k' is "kong空" */ printf(" so the buf%d c

15、hanged to empty-%cn", rear, bufrear); void consume_item(int y) printf("cosume the item :the screem print %cn", y); void producer(void); void consumer(void); /* 生產(chǎn)者 */ void producer(void) int item; while(1) produce_item(&item); p(&empty); /* 遞減空槽數(shù) */ p(&mutex); /* 進(jìn)入臨界區(qū) */

16、enter_item(item); /* 將一個(gè)新的數(shù)據(jù)項(xiàng)放入緩沖區(qū) */ v(&mutex); /* 離開臨界區(qū) */ v(&full); /* 遞增滿槽數(shù) */ if(full=n) /* 若緩沖區(qū)滿的話，喚醒消費(fèi)者進(jìn)程 */ consumer(); /* 消費(fèi)者 */ void consumer(void) int get_item; while(1) p(&full); /* 遞減滿槽數(shù) */ p(&mutex); /* 進(jìn)入臨界區(qū) */ remove_item(&get_item); /* 從緩沖區(qū)中取走一個(gè)數(shù)據(jù)項(xiàng) */ v(&mutex); /* 離開臨界區(qū) */ v(&empty); /* 遞增空槽數(shù) */ cons