#include????
#include?
#include?“d_random.h“????????????????//產(chǎn)生隨機(jī)數(shù)用

using?namespace?std;

//#define?MAX_THREAD_NUM?64????????????//最大線程數(shù)目
//int?count?=?0;???????????????????????//統(tǒng)計(jì)線程總數(shù)
HANDLE?h_Mutex;??????????????????????//用于線程間的互斥???
HANDLE?bufferFullSemaphore;??????????//當(dāng)緩沖區(qū)滿時(shí)生產(chǎn)者等待信號量??
HANDLE?bufferEmptySemaphore;?????????//當(dāng)緩沖區(qū)空時(shí)消費(fèi)者等待信號量??????????????????????????????
const?int?BUFFER_SIZE?=?2;???????????//緩沖區(qū)長度
long?buffer[BUFFER_SIZE]?=?{0};????????//緩沖區(qū)循環(huán)隊(duì)列
int?in?=?0;??????????????????????????//用與追蹤產(chǎn)品進(jìn)緩沖區(qū)時(shí)的緩沖區(qū)數(shù)組下標(biāo)
int?out?=?0;????????????????????????//用與追蹤產(chǎn)品出緩沖區(qū)時(shí)的緩沖區(qū)數(shù)組下標(biāo)
randomNumber?rndNum;?????????????????//用于產(chǎn)生隨機(jī)數(shù)（模擬產(chǎn)品）
long?rn;
const?int?PRODUCER_NUM=?3;?????//生產(chǎn)者的個(gè)數(shù)???
const?int?CONSUMER_NUM?=?4;?????//消費(fèi)者的個(gè)數(shù)
DWORD?producerID[PRODUCER_NUM];???//生產(chǎn)者線程的標(biāo)識符???
DWORD?consumerID[CONSUMER_NUM];???//消費(fèi)者線程的標(biāo)識符
bool?control?=?true;??????????????//控制生產(chǎn)者消費(fèi)者線程的循環(huán)???

void?producer1（void）?????//生產(chǎn)者1進(jìn)程
{???
	while（control）{
		//count++;
		WaitForSingleobject（bufferFullSemaphoreINFINITE）;?
????????WaitForSingleobject（h_MutexINFINITE）;
		rn?=?rndNum.random（10000）?+?90000;
????????cout?<			rn?<		buffer[in]?=?rn;???//產(chǎn)品進(jìn)緩沖區(qū)
		in?=?（in?+?1）?%?BUFFER_SIZE;???//循環(huán)緩沖區(qū)指向下一個(gè)儲存空間
		cout?<		for（int?i?=?0;i?		{
			cout?<			if（buffer[i]?==?0）
				cout?<????????????else???
				cout?<此產(chǎn)品可消費(fèi)“;???
????????????????cout?<		}
		cout?<????????Sleep（1000）;???
????????ReleaseMutex（h_Mutex）;???
????????ReleaseSemaphore（bufferEmptySemaphore1NULL）;???
	}?????
}
void?producer2（void）?????//生產(chǎn)者2進(jìn)程
{???
	while（control）{
		//count++;
		WaitForSingleobject（bufferFullSemaphoreINFINITE）;???
????????WaitForSingleobject（h_MutexINFINITE）;
		rn?=?rndNum.random（10000）?+?90000;
????????cout?<			rn?<		buffer[in]?=?rn;???//產(chǎn)品進(jìn)緩沖區(qū)
		in?=?（in?+?1）?%?BUFFER_SIZE;???//循環(huán)緩沖區(qū)指向下一個(gè)儲存空間
		cout?<		for（int?i?=?0;i?		{
			cout?<			if（buffer[i]?==?0）
				cout?<????????????else???
				cout?<此產(chǎn)品可消費(fèi)“;???
????????????????cout?<		}
		cout?<????????Sleep（2000）;???
????????ReleaseMutex（h_Mutex）;???
????????ReleaseSemaphore（bufferEmptySemaphore1NULL）;???
	}?????
}???
void?producer3（void）?????//生產(chǎn)者3進(jìn)程
{???
	while（control）{
		//count++;
		WaitForSingleobject（bufferFullSemaphoreINFINITE）;???
????????WaitForSingleobject（h_MutexINFINITE）;
		rn?=?rndNum.random（10000）?+?90000;
????????cout?<			rn?<