c++中SetEvent和ResetEvent的使用

 

關於事件
　　事件(Event)是WIN32提供的最靈活的線程間同步方式，事件可以處於激發狀態(signaled or true)或未激發狀態(unsignal or false)。根據狀態變遷方式的不同，事件可分為兩類：
　　（1）手動設置：這種對象只可能用程序手動設置，在需要該事件或者事件發生時，采用SetEvent及ResetEvent來進行設置。
　　（2）自動恢復：一旦事件發生並被處理后，自動恢復到沒有事件狀態，不需要再次設置。
　　

創建事件的函數原型為：

 

HANDLE CreateEvent(
　LPSECURITY_ATTRIBUTES lpEventAttributes,
　// SECURITY_ATTRIBUTES結構指針，可為NULL
　BOOL bManualReset, 
　// 手動/自動
　// TRUE：在WaitForSingleObject后必須手動調用ResetEvent清除信號
　// FALSE：在WaitForSingleObject后，系統自動清除事件信號
　BOOL bInitialState, //初始狀態
　LPCTSTR lpName //事件的名稱
);

 

使用"事件"機制應注意以下事項：
　　（1）如果跨進程訪問事件，必須對事件命名，在對事件命名的時候，要注意不要與系統命名空間中的其它全局命名對象沖突；
　　（2）事件是否要自動恢復；
　　（3）事件的初始狀態設置。

 

看下面代碼： 

 

// event.cpp : 定義控制台應用程序的入口點。
//

#include "stdafx.h"
#include <wtypes.h>
#include <iostream>
using namespace std;

DWORD WINAPI ThreadProc(LPVOID lpParam);
DWORD WINAPI ThreadProc2(LPVOID lpParam);

DWORD g_dwThreadID;
DWORD g_dwThreadID2;

UINT g_nTickets = 300;  //int g_nTickets = 300;  //備注1  

HANDLE g_hEvent1 = NULL;
HANDLE g_hEvent2 = NULL;

CRITICAL_SECTION g_cs;

int ThreadCout = 0;

int _tmain(int argc, _TCHAR* argv[])
{
    cout << "Main thread is running." << endl;

    InitializeCriticalSection(&g_cs);//初始化臨界區  

    HANDLE hHandle = CreateThread(NULL, 0, ThreadProc, NULL, 0, &g_dwThreadID);
    ThreadCout++;
    HANDLE hHandle2 = CreateThread(NULL, 0, ThreadProc2, NULL, 0, &g_dwThreadID2);
    ThreadCout++;

    g_hEvent1 = CreateEvent(NULL, FALSE, TRUE, NULL);  //備注5:g_hEvent1 = CreateEvent(NULL, TRUE,  TRUE, NULL);  
    g_hEvent2 = CreateEvent(NULL, FALSE, TRUE, NULL);  //備注5:g_hEvent2 = CreateEvent(NULL, TRUE,  TRUE, NULL);  

    ResetEvent(g_hEvent1);
    ResetEvent(g_hEvent2);

    SetEvent(g_hEvent1);


    while (TRUE)
    {
        EnterCriticalSection(&g_cs);
        int nCount = ThreadCout;
        LeaveCriticalSection(&g_cs);

        if (nCount == 0)
        {
            cout << "Main thread is break." << endl;
            break;
        }

    }


    Sleep(1000);    //備注4     

    CloseHandle(hHandle);
    CloseHandle(hHandle2);

    DeleteCriticalSection(&g_cs);

    cout << "Main thread is end." << endl;

    system("pause");
    return 0;
}


DWORD WINAPI ThreadProc(LPVOID lpParam)
{
    // cout << "No." << g_dwThreadID << " thread is running." << endl;    
    while (TRUE)
    {
        WaitForSingleObject(g_hEvent1, INFINITE);
        cout << "No.1 " << g_dwThreadID << " thread is running." << endl;

        EnterCriticalSection(&g_cs);
        int temp = g_nTickets;
        LeaveCriticalSection(&g_cs);

        cout << "No.1 " << g_dwThreadID << " thread is temp." << endl;

        if (temp > 0)
        {
            Sleep(10);  //Sleep(1000)   //備注2  
            cout << "No.1-" << g_dwThreadID << " sell ticket : " << temp << endl;


            EnterCriticalSection(&g_cs);
            g_nTickets--;
            LeaveCriticalSection(&g_cs);

            SetEvent(g_hEvent2);
            //ResetEvent(g_hEvent1);//備注6  
        }
        else
        {
            cout << "No.1- break" << endl;
            //ResetEvent(g_hEvent1);//備注6  
            SetEvent(g_hEvent2);//沒有這個ThreadProc2不能終止   //備注3  
            break;
        }
    }

    EnterCriticalSection(&g_cs);
    ThreadCout--;
    LeaveCriticalSection(&g_cs);
    cout << "No.1- end" << endl;

    return 0;
}

DWORD WINAPI ThreadProc2(LPVOID lpParam)
{
    //   
    while (TRUE)
    {
        WaitForSingleObject(g_hEvent2, INFINITE);
        cout << "No.2 " << g_dwThreadID2 << " thread is running." << endl;

        EnterCriticalSection(&g_cs);
        int temp = g_nTickets;
        LeaveCriticalSection(&g_cs);

        if (temp > 0)
        {
            Sleep(10);  //Sleep(1000)   //備注2  
            cout << "No.2-" << g_dwThreadID2 << " sell ticket : " << temp << endl;

            EnterCriticalSection(&g_cs);
            g_nTickets--;
            LeaveCriticalSection(&g_cs);

            SetEvent(g_hEvent1);
            //ResetEvent(g_hEvent2);//備注6  
        }
        else
        {
            cout << "No.2- break" << endl;
            //ResetEvent(g_hEvent2);//備注6  
            SetEvent(g_hEvent1);//同樣的問題，沒有這個ThreadProc不能終止      //備注3  
            break;
        }
    }

    EnterCriticalSection(&g_cs);
    ThreadCout--;
    LeaveCriticalSection(&g_cs);

    cout << "No.2- end" << endl;
    return 0;
}

 

這個代碼是接上一遍關於UINT類型作為循環變量的不確定性問題繼續完善的，加入了臨界區控制全局變量的訪問。

本文要說明的是SetEvent和ResetEvent的使用，這個要看備注5和備注6。

備注5處：

CreateEvent的第二個參數決定了是否需要手動調用ResetEvent，當為TRUE時，是需要手動調用，如果不調用，會怎么樣呢？不調用，事件會處於一直有信號狀態，即備注6處。當為FALSE時候，不需要手動調用，調用不調用，效果一樣。把ResetEvent放在WaitForSingleObject前面也是很好的做法。

 

轉載請注明原創鏈接：http://blog.csdn.net/wujunokay/article/details/12272581