此线程词的思想简要介绍如下,START开始后,创建一个管理线程,和最少个数的工作线程序。管理线程序用来管理工作线程的多少。工作线程序在调用WORK的PROCESSJOB时候先把标志位设定为忙状态,当调用完删设定回去。而管理线程序,每等待6秒查询下状态看有多少线程序正在执行过程中,然后根据一定的比例增加或者减少线程。 其他主要通过GetQueuedCompletionStatus ,PostQueuedCompletionStatus 函数来交换消息。其他前参见源代码。
看到codeproject上对此线程池进行了一些现在把主要思想讲出来,其源码如下
unsigned int CThreadPool::ManagerProc(void* p)
{
//convert the parameter to the server pointer.
CThreadPool* pServer=(CThreadPool*)p;
HANDLE IoPort = pServer->GetMgrIoPort();
unsigned long pN1, pN2;
OVERLAPPED* pOverLapped;
LABEL_MANAGER_PROCESSING:
while(::GetQueuedCompletionStatus(IoPort, &pN1, &pN2,
&pOverLapped, pServer->GetMgrWaitTime() ))
{
if(pOverLapped == (OVERLAPPED*)0xFFFFFFFF)
break;
else
{
TRACE0("mgr events comes in!\n");
}
}
//time out processing
if (::GetLastError()==WAIT_TIMEOUT)
{
//time out processing
TRACE0("Time out processing!\n");
//the manager will take a look at all the worker's status. The
if (pServer->GetThreadPoolStatus()==CThreadPool::BUSY)
pServer->AddThreads();
if (pServer->GetThreadPoolStatus()==CThreadPool::IDLE)
pServer->RemoveThreads();
goto LABEL_MANAGER_PROCESSING;
}
return 0;
}
什么时候可能发生问题,当if(pOverLapped == (OVERLAPPED*)0xFFFFFFFF)
break;退出了循环时候
正好有可能有个可能::GetLastError()==WAIT_TIMEOUT会发生,这样的话导致MANGER并没有结束,这样的话STOP 的WAITFORSINGLEOBJECT就会发生死锁,永远都卡在那里,所以在收到0xFFFFFFF的最直接就是直接RETRUN就行了.