#include????
#include?
#include?“d_random.h“????????????????//產生隨機數用

using?namespace?std;

//#define?MAX_THREAD_NUM?64????????????//最大線程數目
//int?count?=?0;???????????????????????//統計線程總數
HANDLE?h_Mutex;??????????????????????//用于線程間的互斥???
HANDLE?bufferFullSemaphore;??????????//當緩沖區滿時生產者等待信號量??
HANDLE?bufferEmptySemaphore;?????????//當緩沖區空時消費者等待信號量??????????????????????????????
const?int?BUFFER_SIZE?=?2;???????????//緩沖區長度
long?buffer[BUFFER_SIZE]?=?{0};????????//緩沖區循環隊列
int?in?=?0;??????????????????????????//用與追蹤產品進緩沖區時的緩沖區數組下標
int?out?=?0;????????????????????????//用與追蹤產品出緩沖區時的緩沖區數組下標
randomNumber?rndNum;?????????????????//用于產生隨機數（模擬產品）
long?rn;
const?int?PRODUCER_NUM=?3;?????//生產者的個數???
const?int?CONSUMER_NUM?=?4;?????//消費者的個數
DWORD?producerID[PRODUCER_NUM];???//生產者線程的標識符???
DWORD?consumerID[CONSUMER_NUM];???//消費者線程的標識符
bool?control?=?true;??????????????//控制生產者消費者線程的循環???

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