DWORD WaitForMultipleObjects(
- DWORD nCount,
- CONST HANDLE *lpHandles,
- BOOL fWaitAll,
- DWORD dwMilliseconds
- );
-
- 其中参数
-
- nCount 句柄的数量 最大值为MAXIMUM_WAIT_OBJECTS(64)
-
- HANDLE 句柄数组的指针。
-
- HANDLE 类型可以为(Event,Mutex,Process,Thread,Semaphore )数组
-
- BOOL bWaitAll 等待的类型,如果为TRUE 则等待所有信号量有效在往下执行,FALSE 当有其中一个信号量有效时就向下执行
-
- DWORD dwMilliseconds 超时时间 超时后向执行。 如果为WSA_INFINITE 永不超时。如果没有信号量就会在这死等。
-
- 举个例子:当 bWaitAll参数为FALSE 可以等待其中之一的事件
-
- HANDLE m_hEvent[2];
-
-
-
- m_hEvent[0]=::CreateEvent(NULL, FALSE, FALSE, NULL);
-
- m_hEvent[1]=::CreateEvent(NULL, FALSE, FALSE, NULL);
-
- ::CreateThread(NULL, 0, MyThreadProc, this, 0, NULL);
-
- DWORD WINAPI MyThreadProc(LPVOID lpParam)
-
- {
-
- while(TRUE)
-
- {
-
- int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent, FALSE,500);
-
- if (nIndex == WAIT_OBJECT_0 + 1)
-
- {
-
-
-
- }
-
- else if (nIndex == WAIT_OBJECT_0)
-
- {
-
-
-
- }
-
- else if (nIndex == WAIT_TIMEOUT)
-
- {
-
- }
-
- }
-
- ::OutputDebugString("线程结束. /n");
-
- return 0L;}
-
- 当要处理第一个事件时,你只需执行SetEvent(m_hEvent[0]);
-
- 即可进入第一个事件的位置
-
- 当要执行第二个事件时执行SetEvent(m_hEvent[1]);
-
- 当 bWaitAll参数为TRUE 等待所有的事件
-
- DWORD WINAPI MyThreadProc(LPVOID lpParam)
-
- { while(TRUE)
-
- {
-
- int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent, TRUE,500);
-
- if (WAIT_OBJECT_0 + 1<= nIndex <= WAIT_OBJECT_0)
-
- {
-
-
-
- }
-
-
- 文章出处:http:
当WaitForMultipleObjects()等到多个内核对象的时候,
如果它的bWaitAll 参数设置为false。其返回值减去WAIT_OBJECT_0 就是参数lpHandles数组的序号。
如果同时有多个内核对象被出发,这个函数返回的只是其中序号最小的那个。
问题就在这里,我们如何可以获取所有被同时触发的内核对象。
举个例子:我们需要在一个线程中处理从完成端口、数据库、和可等待定时器来的数据。
一个典型的实现方法就是:用WaitForMultipleObjects等待所有的这些事件。
如果完成端口,数据库发过来的数据量非常大,可等待定时器时间也只有几十毫秒。
那么这些事件同时触发的几率可以说非常大,我们不希望丢弃任何一个被触发的事件。那么如何能高效地实现这一处理呢?
多个内核对象被触发时,WaitForMultipleObjects选择其中序号最小的返回。而WaitForMultipleObjects它只会改变使它返回的那个内核对象的状态。
这儿又会产生一个问题,如果序号最小的那个对象频繁被触发,那么序号比它大的内核对象将的不到被出理的机会。
为了解决这一问题,可以采用双WaitForMultipleObjects检测机制来实现。见下面的例子:
DWORD WINAPI ThreadProc(LPVOID lpParameter)
- {
- DWORD dwRet = 0;
- int nIndex = 0;
- while(1)
- {dwRet = WaitForMultipleObjects(nCount,pHandles,false,INFINITE);
- switch(dwRet)
- {
- case WAIT_TIMEOUT:
- break;
- case WAIT_FAILED:
- return 1;
- default:
- {
- nIndex = dwRet - WAIT_OBJECT_0;
- ProcessHanlde(nIndex++);
- {
- dwRet = WaitForMultipleObjects(nCount - nIndex,&pHandles[nIndex],false,0);
- switch(dwRet)
- case WAIT_TIMEOUT:
- nIndex = nCount;
- break;
- case WAIT_FAILED:
- return 1;
- default:
- { nIndex = dwRet - WAIT_OBJECT_0;
- ProcessHanlde(nIndex++);
- }
- break;
- }
- }
- }
- break;
- }
- }
- return 0;
- }