深入解析C++编程中线程池的使用

2020-01-06 14:01:59于海丽

线程池在接受到新的任务之后,线程池首先要检查是否有足够的空闲池可用。检查分为三个步骤:

(1)检查当前处于忙碌状态的线程是否达到了设定的最大值m_MaxNum,如果达到了,表明目前没有空闲线程可用,而且也不能创建新的线程,因此必须等待直到有线程执行完毕返回到空闲队列中。

(2)如果当前的空闲线程数目小于我们设定的最小的空闲数目m_AvailLow,则我们必须创建新的线程,默认情况下,创建后的线程数目应该为m_InitNum,因此创建的线程数目应该为( 当前空闲线程数与m_InitNum);但是有一种特殊情况必须考虑,就是现有的线程总数加上创建后的线程数可能超过m_MaxNum,因此我们必须对线程的创建区别对待。

 

 
  1. if(GetAllNum()+m_InitNum-m_IdleList.size() < m_MaxNum )   
  2. CreateIdleThread(m_InitNum-m_IdleList.size());   
  3. else   
  4. CreateIdleThread(m_MaxNum-GetAllNum()); 

如果创建后总数不超过m_MaxNum,则创建后的线程为m_InitNum;如果超过了,则只创建( m_MaxNum-当前线程总数 )个。

(3)调用GetIdleThread方法查找空闲线程。如果当前没有空闲线程,则挂起;否则将任务指派给该线程,同时将其移入忙碌队列。

当线程执行完毕后,其会调用MoveToIdleList方法移入空闲链表中,其中还调用m_IdleCond.Signal()方法,唤醒GetIdleThread()中可能阻塞的线程。

CJob

CJob类相对简单,其封装了任务的基本的属性和方法,其中最重要的是Run方法,代码如下:

 

 
  1. class CJob  { 
  2.   private: 
  3.   int m_JobNo; //The num was assigned to the job