生产者消费者问题2

//生产者消费者问题
//使用事件和互斥量实现
//缓冲区只能放一个产品

//有人可能疑问，为什么不能用两个互斥量来实现同步，
//像使用两个事件一样。因为互斥量具有线程所有的概念，
//等待函数执行后，互斥量会保存当前线程id，表示这个互斥量属于这个线程。
//当你在另一个线程Release这个互斥量时，因为互斥量保存的线程ID与当前
//线程ID不一致，操作将返回FALSE。
#include <iostream>
#include <Windows.h>

//互斥量
HANDLE g_hMutex;
//事件
HANDLE g_hEventBufferEmpty, g_hEventBufferFull; 
//缓冲区，只能放一个产品
int g_Buffer;     

DWORD WINAPI ProducterThreadFunc(PVOID pM)
{
    int i;
    for(i = 1; i <= 10; i++)
    {
        WaitForSingleObject(g_hEventBufferEmpty, INFINITE);
        //等待互斥量被释放（触发）
        WaitForSingleObject(g_hMutex, INFINITE);
        
        g_Buffer = i;
        std::cout<<"生产者放入产品："<<i<<std::endl;
        //释放互斥量
        ReleaseMutex(g_hMutex);

        SetEvent(g_hEventBufferFull);
    }
    return 0;
}
DWORD WINAPI ConsumerFunc(PVOID pM)
{
    int i;
    for(i = 1; i <= 10; i++)
    {
        WaitForSingleObject(g_hEventBufferFull, INFINITE);
        //等待互斥量触发
        WaitForSingleObject(g_hMutex,INFINITE);
        
        std::cout<<"  消费者拿出产品："<<g_Buffer<<std::endl;
        

        //释放互斥量
        ReleaseMutex(g_hMutex);
        SetEvent(g_hEventBufferEmpty);
    }
    return 0;
}
int main()
{
    //设置互斥量为触发状态（释放）,第2个参数FALSE
    g_hMutex = CreateMutex(NULL, FALSE, NULL);

    
    //事件
    //开始设置缓冲区为空的事件触发，第3个参数
    g_hEventBufferEmpty = CreateEvent(NULL, FALSE, TRUE, NULL);
    //设置缓冲区满的事件未触发
    g_hEventBufferFull = CreateEvent(NULL, FALSE, FALSE, NULL);

    //线程
    HANDLE hThread[2];
    hThread[0] = CreateThread(NULL, 0, ProducterThreadFunc, NULL, 0, NULL);
    
    hThread[1] = CreateThread(NULL, 0, ConsumerFunc, NULL, 0, NULL);
    WaitForMultipleObjects(2, hThread, TRUE, INFINITE); 

    std::cout<<std::endl<<"执行完成。
"<<std::endl;
    CloseHandle(hThread[0]);
    CloseHandle(hThread[1]);

    CloseHandle(g_hEventBufferEmpty);
    CloseHandle(g_hEventBufferFull);
    CloseHandle(g_hMutex);
    return 0;
}