事件SetEvent、RestEvent、WaitForSingleObject與CreateEvent詳解
SetEvent/ResetEvent分別將EVENT置為這兩種狀態分別是發訊號與不發訊號。
WaitForSingleObject()等待,直到引數所指定的OBJECT成為發訊號狀態時才返回,OBJECT可以是EVENT,也可以是其它核心物件。注:WaitForSingleObject的第一個引數一定不能為空。
CreateEvent 用來建立或開啟一個命名的或無名的事件物件,對於它的其他解釋,請自行百科,這裡只簡單描述它的兩種常用用法!
CreateEvent 的定義如下:
HANDLE WINAPI CreateEvent( _In_opt_ LPSECURITY_ATTRIBUTES lpEventAttributes, //安全屬性 _In_ BOOL bManualReset, //設定訊號復位方式為自動恢復為無訊號狀態(FALSE)還是手動恢復為無訊號狀態(TRUE) _In_ BOOL bInitialState, //初始狀態 _In_opt_ LPCTSTR lpName //訊號名稱,可以為Null );
使用方法:
第一種情況 自動恢復到無訊號狀態
hEvent = CreateEvent(NULL, FALSE, TRUE, NULL); //復位方式為自動恢復到無訊號狀態,且初始狀態為有訊號.
DWORD dReturn = WaitForSingleObject(hEvent, 等待時間); // 即呼叫完該方法後,hEvent 就變為無訊號狀態, 需要呼叫setEvent使其為有訊號狀態
hEvent 就會變為無訊號狀態,如果在某個時候再次需要上面的式子成立並通過,則需要使用下面的語句使其變為有訊號狀態(此方式只能解鎖一個等待執行緒,如需繼續解鎖,則需要再次使用下面的式子)
SetEvent(hEvent)
第二種情況手動恢復到無訊號狀態
hEvent = CreateEvent(NULL, TRUE, TRUE, NULL); //復位方式為手動恢復到無訊號狀態,且初始狀態為有訊號.
DWORD dReturn = WaitForSingleObject(hEvent, 等待時間); //呼叫該方法後,事件會自動變為有訊號
hEvent 就會自動再次變為有訊號狀態,上面的式子會直接執行並通過(同時有多個等待執行緒也會直接執行並通過),如果需要將hEvent設定為無訊號狀態,則需要手動使用下面的語句:
ResetEvent(hEvent);
注:上面的復位方式指的是恢復到無訊號狀態的方式,若設定為TRUE,則表示需要手動將其置為無訊號,若為FALSE,則會自動變為無訊號,千萬別和訊號量變為有訊號狀態的方式搞混了!
下面附上程式碼:
HANDLE g_event = NULL;
void ThreadFunc1(LPVOID pParam)
{
DWORD wait;
** wait = ::WaitForSingleObject(g_event/*g_event*/, INFINITE);**
for (int i = 0; i < 100; i++)
{
**wait = ::WaitForSingleObject(g_event/*g_event*/, INFINITE);**
printf("ThreadFunc1:%d\n", i);
Sleep(100);
}
}
void ThreadFunc2(LPVOID pParam)
{
for (int i = 0; i < 5; i++)
{
printf("ThreadFunc2:%d\n", i);
**SetEvent(g_event);**
Sleep(1000);
**ResetEvent(g_event);**
}
**Sleep(5000);
SetEvent(g_event);**
}
int main()
{
DWORD m_ThreadID[2];
g_event = ::CreateEvent(NULL, TRUE, FALSE, NULL);
ResetEvent(g_event);
::CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFunc1, NULL, 0, &m_ThreadID[0]);
::CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFunc2, NULL, 0, &m_ThreadID[1]);
getchar();
return 0;
}
結合定義可以修改上述的回撥函式裡面的waitForsingleObject,SetEvent,ResetEvent(即用雙星括起來的部分)就可以控制執行緒1的列印結果。
最後在說一哈WaitForMultipleObjects的用法:
程式碼:
HANDLE g_event = ::CreateEvent(NULL, FALSE, FALSE, NULL);
HANDLE g_event1 = ::CreateEvent(NULL, FALSE, FALSE, NULL);
HANDLE hEvents[2] = { g_event, g_event1 };
void ThreadFunc3(LPVOID pParam)
{
DWORD wait = -1;
bool flge = true;
while (flge)
{
DWORD wait = WaitForMultipleObjects(2, hEvents, FALSE, INFINITE);
#if 0
if (wait == WAIT_OBJECT_0 + 1)
{
cout << "第一個事件發生" << endl;
}
else if (wait == WAIT_OBJECT_0) //第一個事件發生
{
cout << "第二個事件發生" << endl;
flge = false;
}
else if (wait == WAIT_TIMEOUT) //超時500毫秒
{ //超時可作定時用
cout << "在給定的時間內2個事件都沒有發生" << endl;
}
#endif
if (wait == WAIT_OBJECT_0)
{
cout << "第一個事件發生" << endl;
flge = false;
}
}
cout << "第一個事件執行緒退出。" << endl;
}
void ThreadFunc4(LPVOID pParam)
{
DWORD wait = -1;
bool flge = true;
while (flge)
{
DWORD wait = WaitForMultipleObjects(2, hEvents, FALSE, INFINITE);
#if 0
if (wait == WAIT_OBJECT_0 + 1)
{
cout << "第一個事件發生" << endl;
}
else if (wait == WAIT_OBJECT_0) //第一個事件發生
{
cout << "第二個事件發生" << endl;
flge = false;
}
else if (wait == WAIT_TIMEOUT) //超時500毫秒
{ //超時可作定時用
cout << "在給定的時間內2個事件都沒有發生" << endl;
}
#endif
if (wait == WAIT_OBJECT_0 + 1)
{
cout << "第二個事件發生" << endl;
flge = false;
}
}
cout << "第二哥事件執行緒退出。" << endl;
}
主函式:
int main()
{
::CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFunc3, NULL, 0, NULL/*&m_ThreadID[0]*/);
::CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFunc4, NULL, 0, NULL/* &m_ThreadID[1]*/);
SetEvent(hEvents[0]);
SetEvent(hEvents[1]);
Sleep(5000);
return 0;
}
程式碼中WaitForMultipleObjects使用的是隻要一個事件為有訊號就返回, 如果想全部事件都有訊號後再返回執行將第三個引數改為TRUE即可。