操作系統(tǒng)原理課 【進(jìn)程同步】生產(chǎn)者消費(fèi)者程序?qū)嵗a

1、#include #include const unsigned short size_of_buffer = 10; /緩沖區(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í)的下標(biāo) unsigned short out = 0; /產(chǎn)品出緩沖區(qū)時(shí)的下標(biāo) int g_buffersize_of_buffer; /緩沖區(qū)是個(gè)循環(huán)隊(duì)列 bool g_continue = true; /控制程序結(jié)束 handle g_hmutex;

2、 /用于線程間的互斥 handle g_hfullitems; /緩沖區(qū)中被占用的項(xiàng) handle g_hemptyitems; /緩沖區(qū)中的空項(xiàng) 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_hfullitems = createsemaphore(null,0,size_of_buffer,null); g_hemptyitems = createsemaph

3、ore(null,size_of_buffer, size_of_buffer,null); /緩沖區(qū)初始化 for (int i = 0; i size_of_buffer;+i) g_bufferi = -1; /當(dāng)值為-1時(shí)該項(xiàng)為空 /調(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

4、 short threads_count = producers_count+consumers_count; handle hthreadsthreads_count; /各線程的handle dword produceridproducers_count; /生產(chǎn)者線程的標(biāo)識(shí)符 dword consumeridconsumers_count; /消費(fèi)者線程的標(biāo)識(shí)符 /創(chuàng)建生產(chǎn)者線程 for (int i=0;iproducers_count;+i) hthreadsi =createthread(null,0,producer,null,0,&produceridi); if (hthre

5、adsi=null) return -1; /創(chuàng)建消費(fèi)者線程 for (int i=0;iconsumers_count;+i) hthreadsproducers_count+i =createthread(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:cout pr

6、oducing +productid . ; std:cout succeed std:endl; /把新生產(chǎn)的產(chǎn)品放入緩沖區(qū) void append() std:cout appending a product . ; g_bufferin = productid; in = (in+1)%size_of_buffer; std:cout succeed std:endl; /輸出緩沖區(qū)當(dāng)前的狀態(tài) for (int i=0;isize_of_buffer;+i) std:cout i : ; if (g_bufferi=-1) std:cout null; else std:cout g_b

7、ufferi; if (i=in) std:cout t - 生產(chǎn); if (i=out) std:cout t - 消費(fèi); std:cout std:endl; /從緩沖區(qū)中取出一個(gè)產(chǎn)品 void take() std:cout taking a product . ; consumeid = g_bufferout; g_bufferout= -1; out = (out+1)%size_of_buffer; std:cout succeed std:endl; /輸出緩沖區(qū)當(dāng)前的狀態(tài) for (int i=0;isize_of_buffer;+i) std:cout i : ; if (

8、g_bufferi=-1) std:cout null; else std:cout g_bufferi; if (i=in) std:cout t - 生產(chǎn); if (i=out) std:cout t - 消費(fèi); std:cout std:endl; /消耗一個(gè)產(chǎn)品 void consume() std:cout consuming consumeid . ; std:cout succeed std:endl; /生產(chǎn)者 dword winapi producer(lpvoid lppara) while(g_continue) waitforsingleobject(g_hemptyitems,infinite); waitforsingleobject(g_hmutex,infinite); produce(); append(); sleep(1500); releasemutex(g_hmutex); releasesemaphore(g_hfullitems,1,null); return 0; /消費(fèi)者 dword winapi consumer(lpvoid lppara) while(g_continue) waitforsingleobject(g_hfullitems,infinite); waitfo