用 C++ 寫線程池是怎樣一種體驗？

線程池，最簡單的就是生產者消費者模型了。池裡的每條線程，都是消費者，他們消費並處理一個個的任務。生產者可以是demulitplier或者等在select/epoll/kqueue之類的系統api上的，然後他把收集到底任務發出去。

一般來說實現一個線程池主要包括以下4個組成部分：

1）線程管理器：用於創建並管理線程池。事實上線程管理器都有可能包括4）甚至2）3）

2）工作線程：線程池中實際執行任務的線程。在初始化線程時會預先創建好固定數目的線程在池中，這些初始化的線程一般處於空閑狀態，一般不佔用CPU，佔用較小的內存空間。

3）任務介面：每個任務必須實現的介面，當線程池的任務隊列中有可執行任務時，被空閑的工作線程調去執行（線程的閑與忙是通過互斥量實現的，跟前面文章中的設置標誌位差不多），把任務抽象出來形成介面，可以做到線程池與具體的任務無關。

4）任務隊列：用來存放沒有處理的任務，提供一種緩衝機制，實現這種結構有好幾種方法，常用的是隊列，主要運用先進先出原理，另外一種是鏈表之類的數據結構，可以動態的為它分配內存空間，應用中比較靈活。

以Java的ThreadPoolExecutor為例，
線程管理器--------public class ThreadPoolExecutor extends AbstractExecutorService
工作線程---------- private final class Worker implements Runnable

任務介面------------ public interface Runnable
(提交的Callable對象也被封裝成Runnable對象最後)
任務隊列------------ private final BlockingQueue& workQueue;


Doug Lea


對ThreadPoolExecutor進行了重寫，寫的面目全非。。。。。，先分析1.6的吧

http://www.cnblogs.com/elvinni/p/4162726.html


上面是1.7的源碼分析


Linux/Unix下的POSIX規範的C++線程池


也不是我寫的，只是提供給大家鑒賞一下，多多學習吧

http://blog.csdn.net/zhoubl668/article/details/8927090


Thread.h

#ifndef __THREAD_H
#define __THREAD_H

#endif


//Thread.cpp
#include "Thread.h"
#include &

/**
* 創建線程
*/
int CThreadPool::Create()
{
pthread_id = (pthread_t*)malloc(sizeof(pthread_t) * m_iThreadNum);
for(int i = 0; i &< m_iThreadNum; i++) { pthread_create(pthread_id[i], NULL, ThreadFunc, NULL); } return 0; } /** * 停止所有線程 */ int CThreadPool::StopAll() { /** 避免重複調用 */ if (shutdown) { return -1; } printf("Now I will end all threads!!/n"); /** 喚醒所有等待線程，線程池要銷毀了 */ shutdown = true; pthread_cond_broadcast(m_pthreadCond); /** 阻塞等待線程退出，否則就成殭屍了 */ for (int i = 0; i &< m_iThreadNum; i++) { pthread_join(pthread_id[i], NULL); } free(pthread_id); pthread_id = NULL; /** 銷毀條件變數和互斥體 */ pthread_mutex_destroy(m_pthreadMutex); pthread_cond_destroy(m_pthreadCond); return 0; } /** * 獲取當前隊列中任務數 */ int CThreadPool::getTaskSize() { return m_vecTaskList.size(); }

#include "Thread.h"
#include &

for(int i = 0; i &< 20; i++) { threadPool.AddTask(taskObj); } while(1) { printf("there are still %d tasks need to handle/n", threadPool.getTaskSize()); if (threadPool.getTaskSize() == 0) { if (threadPool.StopAll() == -1) { printf("Now I will exit from main/n"); exit(0); } } sleep(2); } return 0; }

/**
* 執行任務的類，設置任務數據並執行
*/
class CTask


CTask類就是3）任務介面 ，該類又run方法用於執行任務，實現此定義的類都是任務對象

/**
* 線程池管理類的實現
*/
class CThreadPool


CThreadPool就是1）線程池管理類 負責創建及管理線程

static vector& m_vecTaskList; /** 任務列表 */


CThreadPool對象的成員變數就是4）任務隊列，存在於線程池管理類中

while (m_vecTaskList.size() == 0 !shutdown)
{
pthread_cond_wait(m_pthreadCond, m_pthreadMutex);
}


3）處理關閉

if (shutdown)
{
pthread_mutex_unlock(m_pthreadMutex);
printf("thread %lu will exit/n", pthread_self());
pthread_exit(NULL);
}


4）取出一個任務並處理

printf("tid %lu run/n", tid);
vector&::iterator iter = m_vecTaskList.begin();

/**
* 取出一個任務並處理之
*/
CTask* task = *iter;
if (iter != m_vecTaskList.end())
{
task = *iter;
m_vecTaskList.erase(iter);
}


pthread_mutex_unlock(m_pthreadMutex);


task-&>Run(); /** 執行任務 */
printf("tid:%lu idle/n", tid);


線程池的實現，請參照

多線程編程―線程池的實現 - 自強不息 厚德載物 - 51CTO技術博客