1、說明
事件的同步是一個很麻煩的區(qū)域,雖然有很多方法去處理它。市面上也有很多書和文章介紹怎樣避免多線程產(chǎn)生的噩夢。通過處理這些噩夢,我漸漸理解了WIN32的事件(Win32 Kernel objects)。在最初時,我不能理解怎么通過在線程中使用全局變量來使用全局的核心事件;后來我理解后,我發(fā)現(xiàn)這個是很容易來使用的。這里,我將解釋Win32事件中關于自動和手動設置重置事件的內(nèi)容。
2、關于Win32 Events
Win32 Events也像其他的核心對象一樣在跨進程是可利用的。一個Win32事件就是一個狀態(tài)機,它的生命期間基于2種狀態(tài)--Signaled state(激活狀態(tài),有信號狀態(tài)) and Non Signaled state(為激活狀態(tài),無信號狀態(tài))。 一個事件處于激活狀態(tài),意味著這個事件可以停止正在等待這個激活信號的線程;而一個處于非激活狀態(tài)的,意味著它不能停止這個正在等待這個事件信號的線程。
3、自動重置Win32事件
自動重置事件----它保證關閉單線程(這個單線程正處于等待這個事件的發(fā)生,然后返回到非激活狀態(tài));如果有多個線程正在同時等待這個事件信號,這些線程是隨機觸發(fā)關閉的。
一些Win32事件創(chuàng)建和使用的API:
CreateEvent(
); //創(chuàng)建事件的API
CreateThread(
); //創(chuàng)建線程的API

//等待一個事件(信號)的API
WaitForSingleObject(
);
WaitForMultipleObject(
);

OpenHandle(
); //獲得一個事件句柄的API
SetEvent(
); //使一個事件處于激活狀態(tài)的API
ResetEvent(
); //使一個事件處于非激活狀態(tài)的API
CloseHandle(
); //關閉事件句柄的API
下面是自動重置事件的相關代碼(VS2010):
#include <Windows.h>
#include <iostream>

using namespace std;

// 需要激活的線程
DWORD WINAPI ThreadFun(LPVOID n)


{
cout << "Thread Instantiated
" << endl;

// 獲得激活事件的句柄(以"MyEvent"為標識)
HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, false, (LPCWSTR)"MyEvent"); // (LPCWSTR)在vs2010,不加入的話會報錯
if (!hEvent)

{
return -1;
}

// 循環(huán)2次
for (int count = 0; count < 2; ++count)

{
// 等待,直到hEvent事件被激活
WaitForSingleObject(hEvent, INFINITE);

cout << "Got The Signal
.." << endl;
}

// 關閉事件的句柄
CloseHandle(hEvent);

cout << "End The Thread
" << endl;

return 0;
}

int main()


{
// 創(chuàng)建一個自動重置事件("MyEvent"為它的標識):當它被激活后將自動重置為未激活狀態(tài)
HANDLE hEvent = CreateEvent(NULL, false, false, (LPCWSTR)"MyEvent");
if (!hEvent)

{
return -1;
}

// 創(chuàng)建一個線程,這個線程執(zhí)行ThreadFun()函數(shù)
DWORD Id;
HANDLE hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFun, 0, 0, &Id); // LPTHREAD_START_ROUTINE:指向一個函數(shù),該函數(shù)通知宿主某個線程已開始執(zhí)行。(MSDN)
if (!hThread)

{
CloseHandle(hEvent);
return -1;
}

// 在開始前等待1秒。。。。。
Sleep(1000);

// 循環(huán)2次(事件被激活2次)
for (int count = 0; count < 2; ++count)

{
// 激活hEvent事件
SetEvent(hEvent);

// 在發(fā)送第二次激活狀態(tài)前等待2秒
Sleep(2000);
}

// 等待hThread這個線程的結束
WaitForSingleObject(hThread, INFINITE);

CloseHandle(hEvent);
CloseHandle(hThread);

cout << "" << endl;

return 0;
}
// 附加
/****定義全局的
CreateEvent(NULL, false, false, (LPCWSTR)"Global\\MyEvent");
“Global\\xxxEvent ”可以保證:在創(chuàng)建命名時間對象時指定名字是全局的。
這樣做的好處如下:
這樣創(chuàng)建的內(nèi)核對象無論出于服務,還是內(nèi)核中,應用層都可以打開并使用這個內(nèi)核對象。
CreateEvent( NULL, FALSE, FALSE, "Global\\CSAPP" ); 這是一個內(nèi)核對象。
*/
說明:上面的代碼通過調(diào)用“CreateEvent ( NULL , false , false , "MyEvent" ); ”來創(chuàng)建一個事件,他的參數(shù)說明如下(網(wǎng)絡搜索到的):
有四個參數(shù),分別注解
LPSECURITY_ATTRIBUTES pEventAttributes :安區(qū)參數(shù) 一般用戶不用考慮它
BOOL bManualReset:表示SetEvent 置位,WaitForSingleObject使用以此后;信號量的有無,為TRUE 的時候,表示有信號,為FALSE為無信號,也可以理解為SetEvent 的作用是置一次信號,與PulseEvent函數(shù)作用相同了。(我的理解:就是是否能過自動重置為未激活狀態(tài)。false時意味是可以自動重置的,true表示必須手動,即調(diào)用ResetEvent)
BOOL bInitialState:表示初始時的信號量有無,為TRUE 的時,表示有信號,反之無信號
LPCTSTR lpName:信號量的別名
其中主要以BOOL bManualReset,BOOL bInitialState的使用最為重要,采用那種配對方式取決于程序的工作方式了。
4、手動重置Win32事件
需要手動來重置,只要在創(chuàng)建事件時把第二個參數(shù)由false改為true即可。這意味著在將事件激活后,如果需要使事件為非激活的狀態(tài),必須手動(explicit明確)的調(diào)用API(ResetEvent)。下面的代碼和上面的很相似,只在main中重置事件為非激活狀態(tài)時,加入了一些代碼:
#include <Windows.h>
#include <iostream>

using namespace std;

// 需要激活的線程
DWORD WINAPI ThreadFun(LPVOID n)


{
cout << "Thread Instantiated
" << endl;

// 獲得激活事件的句柄(以"MyEvent"為標識)
HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, false, (LPCWSTR)"MyEvent"); // (LPCWSTR)在vs2010,不加入的話會報錯
if (!hEvent)

{
return -1;
}

// 循環(huán)2次
for (int count = 0; count < 2; ++count)

{
// 等待,直到hEvent事件被激活
WaitForSingleObject(hEvent, INFINITE);

cout << "Got The Signal
.." << endl;

// 使hEvent該事件的狀態(tài)為非激活狀態(tài)
ResetEvent(hEvent);
cout << "Reset The Event No Signal
.." << endl;
}

// 關閉事件的句柄
CloseHandle(hEvent);

cout << "End The Thread
" << endl;

return 0;
}

int main()


{
// 創(chuàng)建一個自動重置事件("MyEvent"為它的標識):當它被激活后將自動重置為未激活狀態(tài)
HANDLE hEvent = CreateEvent(NULL, false, false, (LPCWSTR)"MyEvent");
if (!hEvent)

{
return -1;
}

// 創(chuàng)建一個線程,這個線程執(zhí)行ThreadFun()函數(shù)
DWORD Id;
HANDLE hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFun, 0, 0, &Id); // LPTHREAD_START_ROUTINE:指向一個函數(shù),該函數(shù)通知宿主某個線程已開始執(zhí)行。(MSDN)
if (!hThread)

{
CloseHandle(hEvent);
return -1;
}

// 在開始前等待1秒。。。。。
Sleep(1000);

// 循環(huán)2次(事件被激活2次)
for (int count = 0; count < 2; ++count)

{
// 激活hEvent事件
SetEvent(hEvent);

// 在發(fā)送第二次激活狀態(tài)前等待2秒
Sleep(2000);
}

// 等待hThread這個線程的結束
WaitForSingleObject(hThread, INFINITE);

CloseHandle(hEvent);
CloseHandle(hThread);

cout << "" << endl;

return 0;
}
這篇文件主要講在多線程中控制線程的激活、等待、退出等處理形式。
原文地址:
http://www.codeproject.com/KB/winsdk/Win32_Event_Handling.aspx 源碼下載:
原作者代碼:
/Files/tiger7/Win32_Event_Handling.zip VS2010代碼:
/Files/tiger7/Thread_Sync.rar