转载：CreateEvent和SetEvent函数

作者

当你创建一个线程时，其实那个线程是一个循环，不像上面那样只运行一次的。这样就带来了一个问题，在那个死循环里要找到合适的条件退出那个死循环，那么是怎么样实现它的呢？在Windows里往往是采用事件的方式，当然还可以采用其它的方式。在这里先介绍采用事件的方式来通知从线程运行函数退出来，它的实现原理是这样，在那个死循环里不断地使用WaitForSingleObject函数来检查事件是否满足，如果满足就退出线程，不满足就继续运行。当在线程里运行阻塞的函数时，就需要在退出线程时，先要把阻塞状态变成非阻塞状态，比如使用一个线程去接收网络数据，同时使用阻塞的SOCKET时，那么要先关闭SOCKET，再发送事件信号，才可以退出线程的。下面就来演示怎么样使用事件来通知线程退出来。

　函数CreateEvent声明如下：

WINBASEAPI
__out
HANDLE
WINAPI
CreateEventA(
　　　　__in_opt　LPSECURITY_ATTRIBUTES　lpEventAttributes,
　　　　__in　　　　　BOOL　bManualReset,
　　　　__in　　　　　BOOL　bInitialState,
　　　　__in_opt　LPCSTR　lpName
　　　　);
WINBASEAPI
__out
HANDLE
WINAPI
CreateEventW(
　　　　__in_opt　LPSECURITY_ATTRIBUTES　lpEventAttributes,
　　　　__in　　　　　BOOL　bManualReset,
　　　　__in　　　　　BOOL　bInitialState,
　　　　__in_opt　LPCWSTR　lpName
　　　　);
#ifdef　UNICODE
#define　CreateEvent　CreateEventW
#else
#define　CreateEvent　CreateEventA
#endif　//　!UNICODE

lpEventAttributes： 　　

[输入]一个指向SECURITY_ATTRIBUTES结构的指针，确定返回的句柄是否可被子进程继承。如果lpEventAttributes是NULL，此句柄不能被继承。
Windows NT/2000：lpEventAttributes的结构中的成员为新的事件指定了一个安全符。如果lpEventAttributes是NULL，事件将获得一个默认的安全符。　　

bManualReset： 　　

[输入]指定将事件对象创建成手动复原还是自动复原。
如果是TRUE，那么必须用ResetEvent函数来手工将事件的状态复原到无信号状态。
如果设置为FALSE，当事件被一个等待线程释放以后，系统将会自动将事件状态复原为无信号状态。 　　

bInitialState： 　　

[输入]指定事件对象的初始状态。如果为TRUE，初始状态为有信号状态；否则为无信号状态。　　

lpName： 　　

[输入]指定事件的对象的名称，是一个以0结束的字符串指针。名称的字符格式限定在MAX_PATH之内。名字是对大小写敏感的。
如果lpName指定的名字，与一个存在的命名的事件对象的名称相同，函数将请求EVENT_ALL_ACCESS来访问存在的对象。
这时候，由于bManualReset和bInitialState参数已经在创建事件的进程中设置，这两个参数将被忽略。
如果lpEventAttributes是参数不是NULL，它将确定此句柄是否可以被继承，但是其安全描述符成员将被忽略。
如果lpName为NULL，将创建一个无名的事件对象。

CEvent::SetEvent()把对象设置为有信号状态，释放等待的线程。
CEvent::ResetEvent()把对象设置为无信号状态，程序在WaitForSingleObject(hHandle,INFINITE)处等待。　

　调用这个函数的例子如下：

#pragma　once

//线程类。
//蔡军生　2007/09/23　QQ:9073204

class　CThread
{
public:
 
　CThread(void)
　{
　　　　　　　　　m_hThread　=　NULL;
　　　　　　　　　m_hEventExit　=　NULL;
　}
 
　virtual　~CThread(void)
　{
　　　　　　　　if　(m_hThread)
　　　　　　　　{
　　　　　　　　　　　　　　//删除的线程资源。
　　　　　　　　　　　　　　::CloseHandle(m_hThread);
　　　　　　　　}
 
　　　　　　　　if　(m_hEventExit)
　　　　　　　　{
　　　　　　　　　　　　　　//删除事件。
　　　　　　　　　　　　　　::CloseHandle(m_hEventExit);
　　　　　　　　}
　　　　　　　
　}
 
　//创建线程
　HANDLE　CreateThread(void)
　{
　　　　　　　　//创建退出事件。
　　　　　　　　m_hEventExit　=　::CreateEvent(NULL,TRUE,FALSE,NULL);
　　　　　　　　if　(!m_hEventExit)
　　　　　　　　　{
　　　　　　　　　　　　　　//创建事件失败。
　　　　　　　　　　　　　　return　NULL;
　　　　　　　　}
 
　　　　　　　　//创建线程。
　　　　　　　　　m_hThread　=　::CreateThread(
　　　　　　　　　　　　　　NULL,　　　　　　　　　　　　　　　　　　　　//安全属性使用缺省。
　　　　　　　　　　　　　　0,　　　　　　　　　　　　　　　　　　　　　　　　　//线程的堆栈大小。
　　　　　　　　　　　　　　ThreadProc,　　　　　　　　　　　　　　　　　//线程运行函数地址。
　　　　　　　　　　　　　　this,　　　　　　　　　　　　　　　　　　　　　　//传给线程函数的参数。
　　　　　　　　　　　　　　0,　　　　　　　　　　　　　　　　　　　　　　　　　//创建标志。
　　　　　　　　　　　　　　&m_dwThreadID);　　　　　　　　//成功创建后的线程标识码。
 
　　　　　　　　return　m_hThread;
　}
 
　//等待线程结束。
　void　WaitFor(DWORD　dwMilliseconds　=　INFINITE)
　{
　　　　　　　　//发送退出线程信号。
　　　　　　　::SetEvent(m_hEventExit);
 
　　　　　　　　//等待线程结束。
　　　　　　　　::WaitForSingleObject(m_hThread,dwMilliseconds);
　}
 
protected:
　//
　//线程运行函数。
　//蔡军生　2007/09/21
　//
　static　DWORD　WINAPI　ThreadProc(LPVOID　lpParameter)
　{
　　　　　　　　//转换传送入来的参数。
　　　　　　　　CThread*　pThread　=　reinterpret_cast<CThread　*>(lpParameter);
　　　　　　　　if　(pThread)
　　　　　　　　{
　　　　　　　　　　　　　　//线程返回码。
　　　　　　　　　　　　　　//调用类的线程处理函数。
　　　　　　　　　　　　　　return　pThread->Run();
　　　　　　　　}
　　　　　　　
　　　　　　　　//
　　　　　　　　return　-1;　　　　　　　
　}
 
　//线程运行函数。
　//在这里可以使用类里的成员，也可以让派生类实现更强大的功能。
　//蔡军生　2007/09/25
　virtual　DWORD　Run(void)
　{
　　　　　　　　//输出到调试窗口。
　　　　　　　　::OutputDebugString(_T("Run()线程函数运行\r\n"));　　　　　
 
　　　　　　　　//线程循环。
　　　　　　　　for　(;;)
　　　　　　　　{
　　　　　　　　　　　　　DWORD　dwRet　=　WaitForSingleObject(m_hEventExit,0);
　　　　　　　　　　　　　　if　(dwRet　==　WAIT_TIMEOUT)
　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　//可以继续运行。　　　　　　　　　　　　　　　　
　　　　　　　　　　　　　　　　　　　TCHAR　chTemp[128];
　　　　　　　　　　　　　　　　　　　wsprintf(chTemp,_T("ThreadID=%d\r\n"),m_dwThreadID);
　　　　　　　　　　　　　　　　　　　::OutputDebugString(chTemp);
 
　　　　　　　　　　　　　　　　　　　　//目前没有做什么事情，就让线程释放一下CPU。
　　　　　　　　　　　　　　　　　　　Sleep(10);
　　　　　　　　　　　　　　}
　　　　　　　　　　　　　　else　if　(dwRet　==　WAIT_OBJECT_0)
　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　//退出线程。
　　　　　　　　　　　　　　　　　　　::OutputDebugString(_T("Run()　退出线程\r\n"));
　　　　　　　　　　　　　　　　　　　break;
　　　　　　　　　　　　　　}
　　　　　　　　　　　　　　else　if　(dwRet　==　WAIT_ABANDONED)
　　　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　　　　//出错。
　　　　　　　　　　　　　　　　　　　::OutputDebugString(_T("Run()　线程出错\r\n"));
　　　　　　　　　　　　　　　　　　　return　-1;
　　　　　　　　　　　　　　}
　　　　　　　　}
 
　　　　　　　　return　0;
　}
 
protected:
　HANDLE　m_hThread;　　　　　　　　　//线程句柄。
　DWORD　m_dwThreadID;　　　　　　　　　　//线程ID。
 
　HANDLE　m_hEventExit;　　　　//线程退出事件。
};

发表评论