C++多线程编程学习三 [FIFO队列设计]

#include <process.h>
#include <windows.h>
#include <queue>
#include <iostream>
#define  BUFSIZ 50
using namespace std;
unsigned _stdcall ThreadWrite(void *X);
unsigned _stdcall ThreadRead(void *X);
queue<int> Buffer;
HANDLE hBufferEvent;
HANDLE hBufferMutex;
void main()
{  
hBufferEvent = CreateEvent(FALSE, TRUE, FALSE, 0);
hBufferMutex = CreateMutex(FALSE, FALSE, FALSE);
ReleaseMutex(hBufferMutex);
unsigned long id_thread_write, id_thread_read;
id_thread_write = _beginthreadex(NULL, 0, ThreadWrite, 0, 0, NULL);
id_thread_read = _beginthreadex(NULL, 0, ThreadRead, 0, 0, NULL);
WaitForSingleObject((HANDLE)id_thread_read, INFINITE);
WaitForSingleObject((HANDLE)id_thread_write, INFINITE);
}
unsigned _stdcall ThreadWrite(void *X)
{
int Item = 1;
while (TRUE)
{  
  if (WAIT_OBJECT_0 == WaitForSingleObject(hBufferMutex, 100))
  {
   if (Buffer.size() == BUFSIZ)
   {
    ReleaseMutex(hBufferMutex);
    continue;
   }
   Buffer.push(Item);   
   ReleaseMutex(hBufferMutex);
   SetEvent(hBufferEvent);
  }
  else
  {
   continue;
  }
  Item++;
  if (Item == 100)
  {
   Sleep(1000);
   Item = 0;
  }
}
cout << "ThreadWrite returned!" << endl;
return 0;
}
unsigned _stdcall ThreadRead(void *x)
{
while(TRUE)
{
  WaitForSingleObject(hBufferEvent, INFINITE);  
 
  if (WAIT_OBJECT_0 == WaitForSingleObject(hBufferMutex, 100))
  {   
   cout << "Value is" << Buffer.front() << endl;
   Buffer.pop();
 
   if (Buffer.empty())
   {
    ResetEvent(hBufferEvent);
    ReleaseMutex(hBufferMutex); 
    continue;
   }
 
   ReleaseMutex(hBufferMutex);   
  }
}
cout << "ThreadRead returned!" << endl;
return 0;
}