生产者消费者问题1

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

#include <iostream>
#include <Windows.h>


//临界区
CRITICAL_SECTION g_cs;
//事件
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);

        EnterCriticalSection(&g_cs);
        g_Buffer = i;
        std::cout<<"生产者放入产品："<<i<<std::endl;
        LeaveCriticalSection(&g_cs);

        SetEvent(g_hEventBufferFull);
    }
    return 0;
}
DWORD WINAPI ConsumerFunc(PVOID pM)
{
    int i;
    for(i = 1; i <= 10; i++)
    {
        WaitForSingleObject(g_hEventBufferFull, INFINITE);

        EnterCriticalSection(&g_cs);
        std::cout<<"  消费者拿出产品："<<g_Buffer<<std::endl;
        LeaveCriticalSection(&g_cs);


        SetEvent(g_hEventBufferEmpty);
    }
    return 0;
}
int main()
{
    //初始化临界区
    InitializeCriticalSection(&g_cs);
    //事件
    //开始设置缓冲区为空的事件触发，第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);
    DeleteCriticalSection(&g_cs);
    return 0;
}