當(dāng)前位置:首頁 > 公眾號精選 > 程序喵大人
[導(dǎo)讀]1.線程池原理我們使用線程的時候就去創(chuàng)建一個線程,這樣實現(xiàn)起來非常簡便,但是就會有一個問題:如果并發(fā)的線程數(shù)量很多,并且每個線程都是執(zhí)行一個時間很短的任務(wù)就結(jié)束了,這樣頻繁創(chuàng)建線程就會大大降低系統(tǒng)的效率,因為頻繁創(chuàng)建線程和銷毀線程需要時間。那么有沒有一種辦法使得線程可以復(fù)用,就是...

1. 線程池原理

我們使用線程的時候就去創(chuàng)建一個線程,這樣實現(xiàn)起來非常簡便,但是就會有一個問題:如果并發(fā)的線程數(shù)量很多,并且每個線程都是執(zhí)行一個時間很短的任務(wù)就結(jié)束了,這樣頻繁創(chuàng)建線程就會大大降低系統(tǒng)的效率,因為頻繁創(chuàng)建線程和銷毀線程需要時間。

那么有沒有一種辦法使得線程可以復(fù)用,就是執(zhí)行完一個任務(wù),并不被銷毀,而是可以繼續(xù)執(zhí)行其他的任務(wù)呢?

線程池是一種多線程處理形式,處理過程中將任務(wù)添加到隊列,然后在創(chuàng)建線程后自動啟動這些任務(wù)。線程池線程都是后臺線程。每個線程都使用默認(rèn)的堆棧大小,以默認(rèn)的優(yōu)先級運行,并處于多線程單元中。如果某個線程在托管代碼中空閑(如正在等待某個事件), 則線程池將插入另一個輔助線程來使所有處理器保持繁忙。如果所有線程池線程都始終保持繁忙,但隊列中包含掛起的工作,則線程池將在一段時間后創(chuàng)建另一個輔助線程但線程的數(shù)目永遠(yuǎn)不會超過最大值。超過最大值的線程可以排隊,但他們要等到其他線程完成后才啟動。

在各個編程語言的語種中都有線程池的概念,并且很多語言中直接提供了線程池,作為程序猿直接使用就可以了,下面給大家介紹一下線程池的實現(xiàn)原理:

線程池的組成主要分為 3 個部分,這三部分配合工作就可以得到一個完整的線程池:

  1. 任務(wù)隊列,存儲需要處理的任務(wù),由工作的線程來處理這些任務(wù)
  • 通過線程池提供的 API 函數(shù),將一個待處理的任務(wù)添加到任務(wù)隊列,或者從任務(wù)隊列中刪除
  • 已處理的任務(wù)會被從任務(wù)隊列中刪除
  • 線程池的使用者,也就是調(diào)用線程池函數(shù)往任務(wù)隊列中添加任務(wù)的線程就是生產(chǎn)者線程
  1. 工作的線程(任務(wù)隊列任務(wù)的消費者) ,N個
  • 線程池中維護(hù)了一定數(shù)量的工作線程,他們的作用是是不停的讀任務(wù)隊列,從里邊取出任務(wù)并處理
  • 工作的線程相當(dāng)于是任務(wù)隊列的消費者角色,
  • 如果任務(wù)隊列為空,工作的線程將會被阻塞 (使用條件變量 / 信號量阻塞)
  • 如果阻塞之后有了新的任務(wù),由生產(chǎn)者將阻塞解除,工作線程開始工作
  1. 管理者線程(不處理任務(wù)隊列中的任務(wù)),1個
  • 它的任務(wù)是周期性的對任務(wù)隊列中的任務(wù)數(shù)量以及處于忙狀態(tài)的工作線程個數(shù)進(jìn)行檢測
  • 當(dāng)任務(wù)過多的時候,可以適當(dāng)?shù)膭?chuàng)建一些新的工作線程
  • 當(dāng)任務(wù)過少的時候,可以適當(dāng)?shù)匿N毀一些工作的線程

2. 任務(wù)隊列

//?任務(wù)結(jié)構(gòu)體
typedef?struct?Task
{
????void?(*function)(void*?arg);
????void*?arg;
}Task;

3. 線程池定義

//?線程池結(jié)構(gòu)體
struct?ThreadPool
{
????//?任務(wù)隊列
????Task*?taskQ;
????int?queueCapacity;??//?容量
????int?queueSize;??????//?當(dāng)前任務(wù)個數(shù)
????int?queueFront;?????//?隊頭?->?取數(shù)據(jù)
????int?queueRear;??????//?隊尾?->?放數(shù)據(jù)

????pthread_t?managerID;????//?管理者線程ID
????pthread_t?*threadIDs;???//?工作的線程ID
????int?minNum;?????????????//?最小線程數(shù)量
????int?maxNum;?????????????//?最大線程數(shù)量
????int?busyNum;????????????//?忙的線程的個數(shù)
????int?liveNum;????????????//?存活的線程的個數(shù)
????int?exitNum;????????????//?要銷毀的線程個數(shù)
????pthread_mutex_t?mutexPool;??//?鎖整個的線程池
????pthread_mutex_t?mutexBusy;??//?鎖busyNum變量
????pthread_cond_t?notFull;?????//?任務(wù)隊列是不是滿了
????pthread_cond_t?notEmpty;????//?任務(wù)隊列是不是空了

????int?shutdown;???????????//?是不是要銷毀線程池,?銷毀為1,?不銷毀為0
};

4. 頭文件聲明

#ifndef?_THREADPOOL_H
#define?_THREADPOOL_H

typedef?struct?ThreadPool?ThreadPool;
//?創(chuàng)建線程池并初始化
ThreadPool?*threadPoolCreate(int?min,?int?max,?int?queueSize);

//?銷毀線程池
int?threadPoolDestroy(ThreadPool*?pool);

//?給線程池添加任務(wù)
void?threadPoolAdd(ThreadPool*?pool,?void(*func)(void*),?void*?arg);

//?獲取線程池中工作的線程的個數(shù)
int?threadPoolBusyNum(ThreadPool*?pool);

//?獲取線程池中活著的線程的個數(shù)
int?threadPoolAliveNum(ThreadPool*?pool);

//////////////////////
//?工作的線程(消費者線程)任務(wù)函數(shù)
void*?worker(void*?arg);
//?管理者線程任務(wù)函數(shù)
void*?manager(void*?arg);
//?單個線程退出
void?threadExit(ThreadPool*?pool);
#endif??//?_THREADPOOL_H

5. 源文件定義

ThreadPool*?threadPoolCreate(int?min,?int?max,?int?queueSize)
{
????ThreadPool*?pool?=?(ThreadPool*)malloc(sizeof(ThreadPool));
????do?
????{
????????if?(pool?==?NULL)
????????{
????????????printf("malloc?threadpool?fail...\n");
????????????break;
????????}

????????pool->threadIDs?=?(pthread_t*)malloc(sizeof(pthread_t)?*?max);
????????if?(pool->threadIDs?==?NULL)
????????{
????????????printf("malloc?threadIDs?fail...\n");
????????????break;
????????}
????????memset(pool->threadIDs,?0,?sizeof(pthread_t)?*?max);
????????pool->minNum?=?min;
????????pool->maxNum?=?max;
????????pool->busyNum?=?0;
????????pool->liveNum?=?min;????//?和最小個數(shù)相等
????????pool->exitNum?=?0;

????????if?(pthread_mutex_init(
本站聲明: 本文章由作者或相關(guān)機構(gòu)授權(quán)發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內(nèi)容真實性等。需要轉(zhuǎn)載請聯(lián)系該專欄作者,如若文章內(nèi)容侵犯您的權(quán)益,請及時聯(lián)系本站刪除。
換一批
延伸閱讀

9月2日消息,不造車的華為或?qū)⒋呱龈蟮莫毥谦F公司,隨著阿維塔和賽力斯的入局,華為引望愈發(fā)顯得引人矚目。

關(guān)鍵字: 阿維塔 塞力斯 華為

加利福尼亞州圣克拉拉縣2024年8月30日 /美通社/ -- 數(shù)字化轉(zhuǎn)型技術(shù)解決方案公司Trianz今天宣布,該公司與Amazon Web Services (AWS)簽訂了...

關(guān)鍵字: AWS AN BSP 數(shù)字化

倫敦2024年8月29日 /美通社/ -- 英國汽車技術(shù)公司SODA.Auto推出其旗艦產(chǎn)品SODA V,這是全球首款涵蓋汽車工程師從創(chuàng)意到認(rèn)證的所有需求的工具,可用于創(chuàng)建軟件定義汽車。 SODA V工具的開發(fā)耗時1.5...

關(guān)鍵字: 汽車 人工智能 智能驅(qū)動 BSP

北京2024年8月28日 /美通社/ -- 越來越多用戶希望企業(yè)業(yè)務(wù)能7×24不間斷運行,同時企業(yè)卻面臨越來越多業(yè)務(wù)中斷的風(fēng)險,如企業(yè)系統(tǒng)復(fù)雜性的增加,頻繁的功能更新和發(fā)布等。如何確保業(yè)務(wù)連續(xù)性,提升韌性,成...

關(guān)鍵字: 亞馬遜 解密 控制平面 BSP

8月30日消息,據(jù)媒體報道,騰訊和網(wǎng)易近期正在縮減他們對日本游戲市場的投資。

關(guān)鍵字: 騰訊 編碼器 CPU

8月28日消息,今天上午,2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會開幕式在貴陽舉行,華為董事、質(zhì)量流程IT總裁陶景文發(fā)表了演講。

關(guān)鍵字: 華為 12nm EDA 半導(dǎo)體

8月28日消息,在2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會上,華為常務(wù)董事、華為云CEO張平安發(fā)表演講稱,數(shù)字世界的話語權(quán)最終是由生態(tài)的繁榮決定的。

關(guān)鍵字: 華為 12nm 手機 衛(wèi)星通信

要點: 有效應(yīng)對環(huán)境變化,經(jīng)營業(yè)績穩(wěn)中有升 落實提質(zhì)增效舉措,毛利潤率延續(xù)升勢 戰(zhàn)略布局成效顯著,戰(zhàn)新業(yè)務(wù)引領(lǐng)增長 以科技創(chuàng)新為引領(lǐng),提升企業(yè)核心競爭力 堅持高質(zhì)量發(fā)展策略,塑強核心競爭優(yōu)勢...

關(guān)鍵字: 通信 BSP 電信運營商 數(shù)字經(jīng)濟(jì)

北京2024年8月27日 /美通社/ -- 8月21日,由中央廣播電視總臺與中國電影電視技術(shù)學(xué)會聯(lián)合牽頭組建的NVI技術(shù)創(chuàng)新聯(lián)盟在BIRTV2024超高清全產(chǎn)業(yè)鏈發(fā)展研討會上宣布正式成立。 活動現(xiàn)場 NVI技術(shù)創(chuàng)新聯(lián)...

關(guān)鍵字: VI 傳輸協(xié)議 音頻 BSP

北京2024年8月27日 /美通社/ -- 在8月23日舉辦的2024年長三角生態(tài)綠色一體化發(fā)展示范區(qū)聯(lián)合招商會上,軟通動力信息技術(shù)(集團(tuán))股份有限公司(以下簡稱"軟通動力")與長三角投資(上海)有限...

關(guān)鍵字: BSP 信息技術(shù)
關(guān)閉
關(guān)閉