分享

WaitForMultipleObjects使用详解

 贫穷的小悍马 2013-06-18

DWORD WaitForMultipleObjects(  
  1.   DWORD nCount,             // number of handles in the handle array   
  2.   CONST HANDLE *lpHandles,  // pointer to the object-handle array   
  3.   BOOL fWaitAll,            // wait flag   
  4.   DWORD dwMilliseconds      // time-out interval in milliseconds   
  5. );  
  6.   
  7. 其中参数   
  8.   
  9. nCount 句柄的数量 最大值为MAXIMUM_WAIT_OBJECTS(64)  
  10.   
  11. HANDLE 句柄数组的指针。  
  12.   
  13. HANDLE 类型可以为(Event,Mutex,Process,Thread,Semaphore )数组  
  14.   
  15. BOOL bWaitAll 等待的类型,如果为TRUE 则等待所有信号量有效在往下执行,FALSE 当有其中一个信号量有效时就向下执行  
  16.   
  17. DWORD dwMilliseconds 超时时间 超时后向执行。 如果为WSA_INFINITE 永不超时。如果没有信号量就会在这死等。  
  18.   
  19. 举个例子:当 bWaitAll参数为FALSE 可以等待其中之一的事件  
  20.   
  21. HANDLE m_hEvent[2];    
  22.   
  23. //两事件   
  24.   
  25. m_hEvent[0]=::CreateEvent(NULL, FALSE, FALSE, NULL);  
  26.   
  27. m_hEvent[1]=::CreateEvent(NULL, FALSE, FALSE, NULL);  
  28.   
  29. ::CreateThread(NULL, 0, MyThreadProc, this, 0, NULL);  
  30.   
  31. DWORD WINAPI MyThreadProc(LPVOID lpParam)  
  32.   
  33. {   
  34.   
  35. while(TRUE)  
  36.   
  37.  {  //每次等500毫秒    
  38.   
  39.  int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent, FALSE,500);     
  40.   
  41.  if (nIndex == WAIT_OBJECT_0 + 1)   
  42.   
  43.  {  
  44.   
  45.  //第二个事件发生   //ExitThread(0);   //break;     
  46.   
  47. }   
  48.   
  49.  else if (nIndex == WAIT_OBJECT_0) //第一个事件发生     
  50.   
  51. {   
  52.   
  53.   //第一个事件   
  54.   
  55.    }    
  56.   
  57. else if (nIndex == WAIT_TIMEOUT) //超时500毫秒     
  58.   
  59. {   //超时可作定时用     
  60.   
  61. }   
  62.   
  63. }  
  64.   
  65.  ::OutputDebugString("线程结束. /n");  
  66.   
  67.  return 0L;}  
  68.   
  69. 当要处理第一个事件时,你只需执行SetEvent(m_hEvent[0]);  
  70.   
  71. 即可进入第一个事件的位置  
  72.   
  73. 当要执行第二个事件时执行SetEvent(m_hEvent[1]);    
  74.   
  75.  当 bWaitAll参数为TRUE 等待所有的事件  
  76.   
  77.  DWORD WINAPI MyThreadProc(LPVOID lpParam)  
  78.   
  79. while(TRUE)  
  80.   
  81.  {  //每次等500毫秒     
  82.   
  83. int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent, TRUE,500);     
  84.   
  85.   if (WAIT_OBJECT_0 + 1<= nIndex <= WAIT_OBJECT_0) //所有事件发生    
  86.   
  87.  {   
  88.   
  89.   //所有的信号量都有效时(事件都发生)其中之一无效。    
  90.   
  91.  }   
  92.   
  93.   
  94. 文章出处:http://www.diybl.com/course/3_program/c++/cppsl/2008711/132765.html  

当WaitForMultipleObjects()等到多个内核对象的时候,

如果它的bWaitAll 参数设置为false。其返回值减去WAIT_OBJECT_0 就是参数lpHandles数组的序号。

如果同时有多个内核对象被出发,这个函数返回的只是其中序号最小的那个。

问题就在这里,我们如何可以获取所有被同时触发的内核对象。

举个例子:我们需要在一个线程中处理从完成端口、数据库、和可等待定时器来的数据。

一个典型的实现方法就是:用WaitForMultipleObjects等待所有的这些事件。

如果完成端口,数据库发过来的数据量非常大,可等待定时器时间也只有几十毫秒。

那么这些事件同时触发的几率可以说非常大,我们不希望丢弃任何一个被触发的事件。那么如何能高效地实现这一处理呢?

 

多个内核对象被触发时,WaitForMultipleObjects选择其中序号最小的返回。而WaitForMultipleObjects它只会改变使它返回的那个内核对象的状态。
这儿又会产生一个问题,如果序号最小的那个对象频繁被触发,那么序号比它大的内核对象将的不到被出理的机会。
 为了解决这一问题,可以采用双WaitForMultipleObjects检测机制来实现。见下面的例子:

 

DWORD WINAPI ThreadProc(LPVOID lpParameter)  
  1. {  
  2. DWORD dwRet = 0;  
  3. int nIndex = 0;   
  4. while(1)  
  5. {dwRet = WaitForMultipleObjects(nCount,pHandles,false,INFINITE);  
  6. switch(dwRet)  
  7. {  
  8. case WAIT_TIMEOUT:  
  9. break;  
  10. case WAIT_FAILED:  
  11. return 1;   
  12. default:   
  13. {   
  14. nIndex = dwRet - WAIT_OBJECT_0;   
  15. ProcessHanlde(nIndex++); //同时检测其他的事件 while(nIndex < nCount)   
  16. {  
  17. dwRet = WaitForMultipleObjects(nCount - nIndex,&pHandles[nIndex],false,0);  
  18. switch(dwRet)  
  19. case WAIT_TIMEOUT:   
  20. nIndex = nCount; //退出检测,因为没有被触发的对象了.    
  21. break;  
  22. case WAIT_FAILED:  
  23. return 1;  
  24. default:   
  25. { nIndex = dwRet - WAIT_OBJECT_0;  
  26. ProcessHanlde(nIndex++);  
  27. }   
  28. break;  
  29. }  
  30. }  
  31. }  
  32. break;  
  33. }  
  34. }   
  35. return 0;  
  36. }  

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多