转载: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;    //线程退出事件。
};

发表评论