workthreadpool.h

来自「在linux下基于UDP通讯的程序,包括客户端与服务端.」· C头文件 代码 · 共 26 行

#ifndef _POOL_H_
#define _POOL_H_

#include "WorkThread.h"
#include <queue>
using namespace std;
//定义线程池
class CWorkThreadPool  
{
public:
	int CleanDeadThreads( );//将运行态结束的线程从线程池中剔除掉
	int StartWorkThread(int nID);//启动一个线程并给它分配一个ID
	int FreeThreads();//空闲线程的个数
	int ThreadSize( );//线程总数
	CWorkThread* FetchFreeThread( );//取出一个空闲的线程
	void AddThread(CWorkThread* th);//添加一个线程到线程队列
	virtual ~CWorkThreadPool();
	CWorkThreadPool(unsigned int nSize = 10);
private:
	int StartScheduleThread( );//开启调度线程
	unsigned int m_nThread;//线程个数
	queue<CWorkThread*> m_pThreadQueue;
};

#endif