一个简单的linux线程池（转-wangchenxicool）

************************************************

代码:

××××××××××××××××××××CThread.h

#ifndef __CTHREAD

#define __CTHREAD

#include

#include

#include

using namespace std;

/**

执行任务的类，设置任务数据并执行

**/

class CTask

{

protected:

string m_strTaskName; //任务的名称

void* m_ptrData; //要执行的任务的具体数据

public:

CTask(){}

CTask(string taskName)

{

this->m_strTaskName = taskName;

m_ptrData = NULL;

}

virtual int Run()= 0;

void SetData(void* data); //设置任务数据

};

/**

线程池

**/

class CThreadPool

{

private:

vector m_vecTaskList; //任务列表

int m_iThreadNum; //线程池中启动的线程数

static vector

m_vecIdleThread; //当前空闲的线程集合

static vector

m_vecBusyThread; //当前正在执行的线程集合

static pthread_mutex_t m_pthreadMutex; //线程同步锁

static pthread_cond_t m_pthreadCond; //线程同步的条件变量

protected:

static void* ThreadFunc(void * threadData); //新线程的线程函数

static int MoveToIdle(pthread_t tid); //线程执行结束后线程池linux，把自己放入到空闲线程中

static int MoveToBusy(pthread_t tid); //移入到忙碌线程中去

int Create(); //创建所有的线程

public:

CThreadPool(int threadNum);

int AddTask(CTask *task); //把任务添加到线程池中

int StopAll();

};

#endif

（编辑：92站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!