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

//等待一個(gè)事件(信號(hào))的API
WaitForSingleObject(
);
WaitForMultipleObject(
);

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

using namespace std;

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


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

// 獲得激活事件的句柄(以"MyEvent"為標(biāo)識(shí))
HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, false, (LPCWSTR)"MyEvent"); // (LPCWSTR)在vs2010,不加入的話會(huì)報(bào)錯(cuò)
if (!hEvent)

{
return -1;
}

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

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

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

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

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

return 0;
}

int main()


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

{
return -1;
}

// 創(chuàng)建一個(gè)線程,這個(gè)線程執(zhí)行ThreadFun()函數(shù)
DWORD Id;
HANDLE hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFun, 0, 0, &Id); // LPTHREAD_START_ROUTINE:指向一個(gè)函數(shù),該函數(shù)通知宿主某個(gè)線程已開始執(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這個(gè)線程的結(jié)束
WaitForSingleObject(hThread, INFINITE);

CloseHandle(hEvent);
CloseHandle(hThread);

cout << "" << endl;

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

using namespace std;

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


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

// 獲得激活事件的句柄(以"MyEvent"為標(biāo)識(shí))
HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, false, (LPCWSTR)"MyEvent"); // (LPCWSTR)在vs2010,不加入的話會(huì)報(bào)錯(cuò)
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;
}

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

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

return 0;
}

int main()


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

{
return -1;
}

// 創(chuàng)建一個(gè)線程,這個(gè)線程執(zhí)行ThreadFun()函數(shù)
DWORD Id;
HANDLE hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadFun, 0, 0, &Id); // LPTHREAD_START_ROUTINE:指向一個(gè)函數(shù),該函數(shù)通知宿主某個(gè)線程已開始執(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這個(gè)線程的結(jié)束
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