1. 程式人生 > >事件SetEvent、RestEvent、WaitForSingleObject與CreateEvent詳解

事件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即可。