Linux下通用线程池的创建与使用(下) （2）

class CWorkerThread:public CThread 

{ 

private: 

CThreadPool* m_ThreadPool; 

CJob* m_Job; 

void* m_JobData; 

CThreadMutex m_VarMutex; 

bool m_IsEnd; 

protected: 

public: 

CCondition m_JobCond; 

CThreadMutex m_WorkMutex; 

CWorkerThread(); 

virtual ~CWorkerThread(); 

void Run(); 

void SetJob(CJob* job,void* jobdata); 

CJob* GetJob(void){return m_Job;} 

void SetThreadPool(CThreadPool* thrpool); 

CThreadPool* GetThreadPool(void){return m_ThreadPool;} 

}; 

CWorkerThread::CWorkerThread() 

{ 

m_Job = NULL; 

m_JobData = NULL; 

m_ThreadPool = NULL; 

m_IsEnd = false; 

} 

CWorkerThread::~CWorkerThread() 

{ 

if(NULL != m_Job) 

delete m_Job; 

if(m_ThreadPool != NULL) 

delete m_ThreadPool; 

} 

void CWorkerThread::Run() 

{ 

SetThreadState(THREAD_RUNNING); 

for(;;) 

{ 

while(m_Job == NULL) 

m_JobCond.Wait(); 
m_Job->Run(m_JobData); 

m_Job->SetWorkThread(NULL); 

m_Job = NULL; 

m_ThreadPool->MoveToIdleList(this); 

if(m_ThreadPool->m_IdleList.size() > m_ThreadPool->GetAvailHighNum()) 

{ 

m_ThreadPool->DeleteIdleThread(m_ThreadPool->m_IdleList.size()-m_T 

hreadPool->GetInitNum()); 

} 

m_WorkMutex.Unlock(); 

} 

} 

void CWorkerThread::SetJob(CJob* job,void* jobdata) 

{ 

m_VarMutex.Lock(); 

m_Job = job; 

m_JobData = jobdata; 

job->SetWorkThread(this); 

m_VarMutex.Unlock(); 

m_JobCond.Signal(); 

} 

void CWorkerThread::SetThreadPool(CThreadPool* thrpool) 

{ 

m_VarMutex.Lock(); 

m_ThreadPool = thrpool; 

m_VarMutex.Unlock(); 

}