C++實現(xiàn)一個簡單的線程池的示例代碼
更新時間：2022年05月19日 08:55:54 作者：phil__naiping
本文主要介紹了C++實現(xiàn)一個簡單的線程池的示例代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
一、設計
線程池應該包括
- 保存線程的容器，保存任務的容器。
- 為了能保證避免線程對任務的競態(tài)獲取，需要對任務隊列進行加鎖。
- 為了使得工作線程感知任務的到來，需要使用條件變量來喚醒工作線程。
- 任務容器中的任務管理。
- 任務的處理API。
二、參數(shù)選擇
使用數(shù)組存放線程，鏈表存放任務。
三、類設計
線程池類
template<typename T>
class threadpool
{
public:
threadpool(int thread_num,int max_request);
~threadpool();
bool append(T* request); // 在任務隊列中添加任務
private:
static void worker(void* arg);
void run();
private:
int m_thread_num; // 線程池中的線程數(shù)
int m_max_request; // 任務隊列最大保存的任務數(shù)
pthread_t *m_threads; // 保存線程的容器
std::list<T*>m_queuework; // 保存任務的鏈表
sem m_sem; // 通知工作線程任務到來
lock m_locker; // 互斥訪問任務隊列
};
構造函數(shù)
template<typename T>
threadpool<T>::threadpool(int thread_num,int max_request):m_thread_num(thread_num),m_max_request(max_request)
{
if(thread_num <=0 || max_request <= 0) throw std::exception();
m_threads = new pthread_t[thread_num];
if(!m_threads) throw std::exception();
for(int i = 0;i < thread_num;++i)
{
// 創(chuàng)建線程
if(pthread_create(m_threads + i, NULL,worker,this)!=0)
{
delete[] m_threads;
throw std::exception();
}
// 分離線程
if(pthread_detach(m_threads[i]))
{
delete[] m_threads;
throw std::exception();
}
}
}
析構函數(shù)
template<typename T>
threadpool<T>::~threadpool()
{
delete[] m_trheads;
}
添加任務函數(shù)
template<typename T>
bool threadpool<T>::append(T* request)
{
m_locker.lock();
if(m_queuework.size() > m_max_request)
{
m_locker.unlock();
return false;
}
m_queuework.push_back(request);
m_locker.unlock();
m_sem.post();
return true;
}
任務處理函數(shù)
template<typename T>
void* threadpool<T>::worker(void*arg)
{
threadpool* pool = (threadpool*)arg;
pool->run();
return pool;
}
template<typename T>
void threadpool<T>::run()
{
while(true)
{
m_sem.wait();
m_locker.lock();
if(m_queuework.empty())
{
m_locker.unlock();
continue;
}
T* request = m_queuework.front();
m_queuework.pop_front();
m_locker.unlock();
request.process(); // 具體任務的處理業(yè)務
}
}
到此這篇關于C++實現(xiàn)一個簡單的線程池的示例代碼的文章就介紹到這了,更多相關C++ 線程池內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹了清除3389遠程登錄日志示例,需要的朋友可以參考下2014-01-01
使用C++和Direct3D (d3d)獲取屏幕截圖并根據(jù)傳入分辨率進行縮放圖片大小(最新推薦)
這篇文章主要介紹了使用C++和Direct3D (d3d)獲取屏幕截圖并根據(jù)傳入分辨率進行縮放圖片大小,本文給大家講解的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-04-04
這篇文章主要給大家介紹了關于C++中this指針的理解與作用的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用C++具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-12-12
隨著公路的大量投運，公路日常養(yǎng)護和管理已經(jīng)成為制約公路運營水平提高的瓶頸，特別是路面狀態(tài)采集、檢測維護等工作更是對傳統(tǒng)的公路運維模式提出了挑戰(zhàn)。這篇文章主要介紹了如何通過Matlab圖像處理實現(xiàn)公路裂縫檢測，感興趣的可以了解一下2022-02-02
mallo函數(shù)返回的實際是一個無類型指針，必須在其前面加上指針類型強制轉換才可以使用，這篇文章主要介紹了c語言malloc函數(shù)的用法示例和意義,需要的朋友可以參考下2022-12-12
本文主要介紹C 語言數(shù)據(jù)類型轉換,這里通過代碼實例進行詳解,這是C語言基礎部分,需要的朋友可以參考下2016-07-07
“地獄回調(diào)”（Callback Hell）是指在編程中使用過多嵌套回調(diào)函數(shù),導致代碼難以閱讀和維護,本文給大家介紹了C++解決回調(diào)地獄問題的方法小結,文中有相關的代碼示例供大家參考,需要的朋友可以參考下2024-07-07
本篇文章是對HDOJ 1443 約瑟夫環(huán)的最新應用進行了詳細的分析介紹，需要的朋友參考下2013-05-05
文章總結了四種解決特定問題的方法,包括單循環(huán)鏈表法、循環(huán)數(shù)組法、遞歸法和迭代法,并分享了個人經(jīng)驗2024-12-12
在我們寫程序時,通過寫時間戳可以方便我們進行日志記錄、調(diào)試、計算程序運行時間、緩存過期控制等,因此下面介紹使用C++代碼獲取時間戳的方法以及一些常見的應用場景,需要的朋友可以參考下2025-08-08