线程池的主要思想及其修正

王朝other·作者佚名  2006-01-10
窄屏简体版  字體: |||超大  

此线程词的思想简要介绍如下,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就行了.

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航