实验一进程同步(3)

{

std::cerr << \ g_buffer[in] = ProductID; in = (in+1)%SIZE_OF_BUFFER; std::cerr << \

//输出缓冲区当前的状态 for (int i=0;i

//从缓冲区中取出一个产品 void Take() {

std::cerr << \ ConsumeID = g_buffer[out]; out = (out+1)%SIZE_OF_BUFFER; std::cerr << \

//输出缓冲区当前的状态 for (int i=0;i

//消耗一个产品 void Consume() {

std::cerr << \ std::cerr << \} //生产者

DWORD WINAPI Producer(LPVOID lpPara) {

while(g_continue){

WaitForSingleObject(g_hFullSemaphore,INFINITE);

WaitForSingleObject(g_hMutex,INFINITE); Produce(); Append(); Sleep(1500);

ReleaseMutex(g_hMutex);

ReleaseSemaphore(g_hEmptySemaphore,1,NULL); } return 0; } //消费者

DWORD WINAPI Consumer(LPVOID lpPara) {

while(g_continue){

WaitForSingleObject(g_hEmptySemaphore,INFINITE); WaitForSingleObject(g_hMutex,INFINITE); Take(); Consume(); Sleep(1500);

ReleaseMutex(g_hMutex);

ReleaseSemaphore(g_hFullSemaphore,1,NULL);

} return 0; }