1、WaitForSingleObject()
函数原型 : DWORD WaitForSingleObject( HANDLE hHandle, DWORDdwMilliseconds);
简单示例代码:
//利用信号量来管理线程池 大致代码如下
HANDLE h_semaphore = CreateSemaphore(NULL, 0, m_thread_pool_size, NULL);
DWORD dwRet = WaitForSingleObject(h_semaphore, INFINITE); //后面是超时时间,这里因为业务需求所以需要无限等待
switch(dwRet)
{
case WAIT_FAILED:
{
cout << "WAIT_FAILED..." << endl;
break;
}
default:
{
TrySubmitThreadpoolCallback((PTP_SIMPLE_CALLBACK)callback_func,
callback_struct, callback_environment); //callback_environment 是在初始化线程池的时候就创建了的,直接在这里传入;callback_struct为一个指针,如果需要传入多个参数,可以用结构体来存储;callback_func 线程池回调函数,具体可以查阅windows核心编程 记住:在子线程里面需要减和增信号量,也就是要修改h_semaphore
}
}
2、WaitForMultipleObjects
函数原型 : DWORD WaitForMultipleObjects(DWORD nCount, CONST HANDLE *lpHandles, BOOL fWaitAll, DWORD dwMilliseconds);
简单示例代码:
//这里无需手动管理信号量,只需知道函数返回成功就处理就可以了
HANDLE h_thread_event = new HANDLE[m_thread_pool_size];
for(int j = 0; j < m_image_thread_pool_size; ++j)
{
h_thread_event[j] = CreateEvent(NULL, TRUE, TRUE, NULL);
}
DWORD dwRet = WaitForMultipleObjects(m_thread_pool_size, h_thread_event, FALSE, INFINITE);
switch(dw_ret)
{
case WAIT_TIMEOUT: break;
case WAIT_FAILED:
{
cout << "WAIT_FAILED..." << endl;
return false;
}
default:
{
int index = dw_ret - WAIT_OBJECT_0;
TrySubmitThreadpoolCallback((PTP_SIMPLE_CALLBACK)callback_func, callback_param, &m_image_callback_environment); //callback_func 回调函数;callback_param 参数,也是一个指针;子线程里面需要知道是哪个线程相应了线程池的需求,并在子线程业务处理好了以后重置线程状态
}
break;
}
虽然两个名称不一样,但是对于多线程的支持,两者是一样的。
转载于:https://blog.51cto.com/11753138/2409859