Win32多线程学习之二（实现生产者与消费者模型）

#include <Windows.h>#include <stdlib.h>#include <stdio.h>#include <process.h>#include <time.h>#include <list> #define MUTEX(mutex) WaitForSingleObject(mutex, INFINITE);#define RELEASE_MUTEX(mutex) ReleaseMutex(mutex); #define P(sem) WaitForSingleObject(sem, INFINITE);#define V(sem) ReleaseSemaphore(sem, 1, NULL); #define CONSUMER_COUNT 10#define PRODUCER_COUNT 5 HANDLE mutex;HANDLE emptySem;HANDLE fullSem;::std::list<int> gList; void initialize(){    mutex = CreateMutex(NULL, false, TEXT("mutex"));    emptySem = CreateSemaphore(NULL, 0, 10, TEXT("empty"));    fullSem = CreateSemaphore(NULL, 10, 10, TEXT("full"));    srand((unsigned int)time(NULL));} int main(){    initialize();    VOID ConsumerThread(VOID* );    VOID ProducerThread(VOID* );    for (int i = 0; i < PRODUCER_COUNT; ++i)    {        _beginthread(ProducerThread, 0, NULL);    }    for (int i = 0; i < CONSUMER_COUNT; ++i)    {       _beginthread(ConsumerThread, 0, NULL);    }    Sleep(3600*1000);    return 0;} VOID ConsumerThread(VOID* argu){    while(true)    {    P(emptySem);    MUTEX(mutex);    printf("Pop a random number %d\n", *gList.rbegin());    gList.pop_back();    RELEASE_MUTEX(mutex);    V(fullSem);    }} VOID ProducerThread(VOID* argu){    while(true)    {    P(fullSem);    MUTEX(mutex);    int random = rand();    gList.push_front(random);    printf("Push a random number: %d\n", random);    RELEASE_MUTEX(mutex);    V(emptySem);    }}