WaitForMultipleObjects使用详解
2015-10-14 22:46
465 查看
DWORD WaitForMultipleObjects(
DWORD nCount,
// number of handles in the
handle array
CONST HANDLE *lpHandles,
// pointer to the object-handle array
BOOL fWaitAll,
// wait flag
DWORD dwMilliseconds
// time-out interval in
milliseconds
);
其中参数
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)
{
//每次等500毫秒
int nIndex = ::WaitForMultipleObjects(2,
pThis->m_hEvent, FALSE,500);
if (nIndex == WAIT_OBJECT_0 +
1)
{
//第二个事件发生
//ExitThread(0); //break;
}
else if (nIndex == WAIT_OBJECT_0) //第一个事件发生
{
//第一个事件
}
else if (nIndex == WAIT_TIMEOUT) //超时500毫秒
{ //超时可作定时用
}
}
::OutputDebugString("线程结束. /n");
return 0L;}
当要处理第一个事件时,你只需执行SetEvent(m_hEvent[0]);
即可进入第一个事件的位置
当要执行第二个事件时执行SetEvent(m_hEvent[1]);
当 bWaitAll参数为TRUE 等待所有的事件
DWORD WINAPI MyThreadProc(LPVOID
lpParam)
{ while(TRUE)
{ //每次等500毫秒
int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent,
TRUE,500);
if (WAIT_OBJECT_0 + 1<= nIndex <=
WAIT_OBJECT_0) //所有事件发生
{
//所有的信号量都有效时(事件都发生)其中之一无效。
}
当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++); //同时检测其他的事件 while(nIndex <
nCount)
{
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;
}
DWORD nCount,
// number of handles in the
handle array
CONST HANDLE *lpHandles,
// pointer to the object-handle array
BOOL fWaitAll,
// wait flag
DWORD dwMilliseconds
// time-out interval in
milliseconds
);
其中参数
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)
{
//每次等500毫秒
int nIndex = ::WaitForMultipleObjects(2,
pThis->m_hEvent, FALSE,500);
if (nIndex == WAIT_OBJECT_0 +
1)
{
//第二个事件发生
//ExitThread(0); //break;
}
else if (nIndex == WAIT_OBJECT_0) //第一个事件发生
{
//第一个事件
}
else if (nIndex == WAIT_TIMEOUT) //超时500毫秒
{ //超时可作定时用
}
}
::OutputDebugString("线程结束. /n");
return 0L;}
当要处理第一个事件时,你只需执行SetEvent(m_hEvent[0]);
即可进入第一个事件的位置
当要执行第二个事件时执行SetEvent(m_hEvent[1]);
当 bWaitAll参数为TRUE 等待所有的事件
DWORD WINAPI MyThreadProc(LPVOID
lpParam)
{ while(TRUE)
{ //每次等500毫秒
int nIndex = ::WaitForMultipleObjects(2, pThis->m_hEvent,
TRUE,500);
if (WAIT_OBJECT_0 + 1<= nIndex <=
WAIT_OBJECT_0) //所有事件发生
{
//所有的信号量都有效时(事件都发生)其中之一无效。
}
当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++); //同时检测其他的事件 while(nIndex <
nCount)
{
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;
}
相关文章推荐
- WaitForMultipleObjects使用详解
- json二级对象数据变成字段串[object Object]
- 《Programming with Objective-C》第七章 Values and Collections
- 基于Theano的深度学习(Deep Learning)框架Keras学习随笔-04-目标函数
- Objective-C:KVO机制
- geodatabase中如何获取feature class的ObjectID
- Android数据解析获取JSONObject的key值-Iterator应用
- Objective-C:KVC机制
- How to prevent object bloat in PostgreSQL
- objective-c制作汤姆猫
- Object - C的知识总结->方法
- iOS/object-c: 枚举类型 enum,NS_ENUM,NS_OPTIONS
- Objective—C常见特性(instancetype和id比较、@property、枚举宏(Enumeration Macros))
- Caused by: java.lang.ClassNotFoundException: com.alibaba.fastjson.JSONObject
- IOS 开发学习(1): 学习纲领以及Objective-C 基本语法学习
- MacTex XeLaTex xdvipdfmx:fatal: pdf_ref_obj(): passed invalid object. 报错的解决方法
- Objective-C的singleton模式
- Objective-C Runtime 运行时之四:Method Swizzling
- 面试题:为什么其他语言里叫函数调用,objective-c里则是给对象发消息(或者谈下对runtime的理解)
- Objective-C Runtime 运行时之三:方法与消息