《线程池原理及创建(C++实现)》由会员分享，可在线阅读，更多相关《线程池原理及创建(C++实现)（31页珍藏版）》请在金锄头文库上搜索。
1、线程池原理及创建（C+实现）时间:2010 02 2514:40:43来源:网络作者未知 点击:2963次 本文给出了一个通用的线程池框架，该框架将与线程执行相关的任务进行了高层次的抽象，使之 与具体的执行任务无关。另外该线程池具有动态伸缩性，它能根据执行任务的轻重自动调整线程 池中线程的数量。文章的最后，我们给出一个本文给出了一个通用的线程池框架，该框架将与线程执行相关的任务进行了高层次的抽象，使之 与具体的执行任务无关。另外该线程池具有动态伸缩性，它能根据执行任务的轻重自动调整线程 池中线程的数量。文章的最后，我们给出一个简单示例程序，通过该示例程序，我们会发现，通 过该线程池框架执行多线
2、程任务是多么的简单。为什么需要线程池目前的大多数网络服务器，包括 Web服务器、Email服务器以及数据库服务器等都具有一个共同 点，就是单位时间内必须处理数目巨大的连接请求，但处理时间却相对较短。传统多线程方案中我们采用的服务器模型则是一旦接受到请求之后，即创建一个新的线程，由该 线程执行任务。任务执行完毕后，线程退出，这就是是“即时创建，即时销毁”的策略。尽管与 创建进程相比，创建线程的时间已经大大的缩短，但是如果提交给线程的任务是执行时间较短， 而且执行次数极其频繁，那么服务器将处于不停的创建线程，销毁线程的状态。我们将传统方案中的线程执行过程分为三个过程：T1、 T2、 T3T1:线程
3、创建时间T2:线程执行时间，包括线程的同步等时间T3:线程销毁时间那么我们可以看出，线程本身的开销所占的比例为(T1+T3)/ (T1+T2+T3。) 如果线程执行的时间很短的话，这比开销可能占到20% 50%左右。如果任务执行时间很频繁的话，这笔开销将是不可忽略 的。除此之外，线程池能够减少创建的线程个数。通常线程池所允许的并发线程是有上界的，如果同 时需要并发的线程数超过上界，那么一部分线程将会等待。而传统方案中，如果同时请求数目为 2000，那么最坏情况下，系统可能需要产生 2000 个线程。尽管这不是一个很大的数目，但是也 有部分机器可能达不到这种要求。因此线程池的出现正是着眼于减少线
4、程池本身带来的开销。线程池采用预创建的技术，在应用程 序启动之后，将立即创建一定数量的线程(N1)，放入空闲队列中。这些线程都是处于阻塞(Suspendec)状态，不消耗CPU但占用较小的内存空间。当任务到来后，缓冲池选择一个空闲 线程，把任务传入此线程中运行。当 N1 个线程都在处理任务后，缓冲池自动创建一定数量的新 线程，用于处理更多的任务。在任务执行完毕后线程也不退出，而是继续保持在池中等待下一次 的任务。当系统比较空闲时，大部分线程都一直处于暂停状态，线程池自动销毁一部分线程，回 收系统资源。基于这种预创建技术，线程池将线程创建和销毁本身所带来的开销分摊到了各个具体的任务上， 执行次数
5、越多，每个任务所分担到的线程本身开销则越小，不过我们另外可能需要考虑进去线程 之间同步所带来的开销。构建线程池框架一般线程池都必须具备下面几个组成部分：线程池管理器 :用于创建并管理线程池工作线程 : 线程池中实际执行的线程任务接口 :尽管线程池大多数情况下是用来支持网络服务器，但是我们将线程执行的任务抽象出来， 形成任务接口，从而是的线程池与具体的任务无关。任务队列 :线程池的概念具体到实现则可能是队列，链表之类的数据结构，其中保存执行线程我们实现的通用线程池框架由五个重要部分组成CThreadManage， CThreadPoo，l CThread， CJob，CWorkerThread,
6、除此之外框架中还包括线程同步使用的类CThreadMutex和CCondition。CJob是所有的任务的基类，其提供一个接口 Run,所有的任务类都必须从该类继承，同时实现 Run方法。该方法中实现具体的任务逻辑。CThread是Linux中线程的包装，其封装了 Linux线程最经常使用的属性和方法，它也是一个抽象 类,是所有线程类的基类,具有一个接口Run。CWorkerThread是实际被调度和执行的线程类，其从 CThread继承而来，实现了 CThread中的Run 方法。CThreadPoo是线程池类，其负责保存线程，释放线程以及调度线程。CThreadMa nage是线程池与用户
7、的直接接口，其屏蔽了内部的具体实现。CThreadMutex用于线程之间的互斥CCondition 则是条件变量的封装,用于线程之间的同步它们的类的继承关系如下图所示：线程池的时序很简单，如下图所示。CThreadMa nage直接跟客户端打交道，其接受需要创建的线程初始个数，并接受客户端提交的任务。这儿的任务是具体的非抽象的任务。CThreadMa nage的内部实际上调用的都是CThreadPool的相关操作。CThreadPoo创建具体的线程，并把客户端提交 的任务分发给CWorkerThread, CWorkerThread实际执行具体的任务。理解系统组件下面我们分开来了解系统中的各个
8、组件。CThreadManageCThreadMa nage的功能非常简单，其提供最简单的方法，其类定义如下:classCThreadManageprivate:CThreadPool* m_Pool;int m_NumOfThread;protected: public:void SetParallelNum(int num);CThreadManage();CThreadManage(intnum);virtual CThreadManage();void Run(CJob*job,void* jobdata);void TerminateAll(void);其中 m_Pool 指向实际的
9、线程池； m_NumOfThread 是初始创建时候允许创建的并发的线程个数。 另外Run和TerminateAII方法也非常简单，只是简单的调用 CThreadPool的一些相关方法而已 其具体的实现如下 :CThreadManage:CThreadManage()m_NumOfThread = 10;m_Pool=new CThreadPool(m_NumOfThread);CThreadManage:CThreadManage(intnum)m_NumOfThread = num;m_Pool = new CThreadPool(m_NumOfThread); CThreadManage
10、:CThreadManage()if(NULL!= m_Pool)delete m_Pool;void CThreadManage:SetParallelNum(intnum) m_NumOfThread = num;void CThreadManage:Run(CJob*job,void* jobdata)m_Pool Run(jobjobdata);void CThreadManage:TerminateAll(void)m_Pool TerminateAII();CThreadCThread类实现了对Linux中线程操作的封装，它是所有线程的基类，也是一个抽象类，提供了一 个抽象接口 R
11、un,所有的CThread都必须实现该Run方法。CThread的定义如下所示： classCThread private:int m_ErrCode;Semaphore m_ThreadSemaphore; /the inner semaphore, which is used to realizeunsigned long m_ThreadID;bool m_Detach; /The thread is detachedbool m_CreateSuspended; /if suspend after creatingchar* m_ThreadName;ThreadStatem_Thre
12、adState; /the state of the thread protected:void SetErrcode(interrcode)m_ErrCode= errcode;static void* ThreadFunction(void*);public:CThread();CThread(boolcreatesuspended,bool detach);virtual CThread();virtual void Run(void)= 0;void SetThreadState(ThreadStatestate)m_ThreadState = state;bool Terminate
13、(void); /Terminate the threabool Start(void); /Start to execute the threadvoid Exit(void);bool Wakeup(void);ThreadState GetThreadState(void)return m_ThreadState;int GetLastError(void)return m_ErrCode;void SetThreadName(char* thrname)strcpy(m_ThreadName,thrname);char* GetThreadName(void)return m_Thre
14、adName;int GetThreadID(void)return m_ThreadID;bool SetPriority(int priority);int GetPriority(void);int GetConcurrency(void);void SetConcurrency(int num);bool Detach(void);bool Join(void);bool Yield(void);int Self(void);线程的状态可以分为四种，空闲、忙碌、挂起、终止 (包括正常退出和非正常退出 )。由于目前Linux线程库不支持挂起操作，因此，我们的此处的挂起操作类似于暂停。如果
15、线程创建后不想立 即执行任务，那么我们可以将其“暂停”，如果需要运行，则唤醒。有一点必须注意的是，一旦 线程开始执行任务，将不能被挂起，其将一直执行任务至完毕。线程类的相关操作均十分简单。线程的执行入口是从 Start()函数开始，其将调用函数ThreadFunction， ThreadFunction 再调用实际的 Run 函数，执行实际的任务。CThreadPoolCThreadPool是线程的承载容器，一般可以将其实现为堆栈、单向队列或者双向队列。在我们的系 统中我们使用STLVector对线程进行保存。CThreadPool的实现代码如下：classCThreadPoolfriend classCWorkerThread;private:unsigned int m_MaxNum; /the maxthread numthat cancreateatthesametimeunsignedintm_AvailLow;/The minnumofidlethread thatshoulekeptunsigned int m_AvailHigh; /The maxnumofidlethread that k
