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;
- }
虽然两个名称不一样, 但是对于多线程的支持, 两者是一样的.
来源: http://www.bubuko.com/infodetail-3096031.html