在上節(jié)內(nèi)容中我們學(xué)習(xí)了線程篇五這節(jié)內(nèi)容我們?cè)敿?xì)講解線程同步.線程同步這是上節(jié)內(nèi)容我們描寫(xiě)的是模擬搶票系統(tǒng)先看這段經(jīng)典的多線程搶票邏輯雖然我們給它加上了互斥鎖來(lái)保護(hù)數(shù)據(jù)但這就像給自習(xí)室門口安了一把只能單人進(jìn)出的鎖依然治不了“搶票狂魔”的問(wèn)題——那個(gè)離鎖最近、手速最快的線程總是能搶在別人前面一遍遍地把票掃光導(dǎo)致其他線程連湯都喝不上只能餓著肚子空轉(zhuǎn)。這種現(xiàn)象在計(jì)算機(jī)里叫“饑餓問(wèn)題”這個(gè)在上節(jié)內(nèi)容中給大家講過(guò)它本身沒(méi)有語(yǔ)法錯(cuò)誤但極其不合理就好比鑰匙剛從墻上的掛鉤摘下還沒(méi)來(lái)得及給別人用同一個(gè)學(xué)生又順手拿了進(jìn)去反復(fù)循環(huán)只圖自己方便。實(shí)際上真正合理的做法必須加上一條“排隊(duì)”規(guī)則任何人用完鑰匙掛回墻上后不能立刻再申請(qǐng)必須老老實(shí)實(shí)去隊(duì)伍后面排隊(duì)。把這個(gè)“按順序辦事”的規(guī)則落實(shí)到代碼里來(lái)保證所有人都能公平地獲取資源就是我們要引入的核心概念——線程同步。排隊(duì)的本質(zhì)就是在互斥保證安全的基礎(chǔ)上賦予線程一個(gè)公平的申請(qǐng)與釋放順序這就是線程同步。它解決的不是數(shù)據(jù)對(duì)不對(duì)而是分配合理不合理的問(wèn)題。正因如此互斥和同步總是成對(duì)出現(xiàn)光有互斥始終無(wú)法保證臨界資源得到有序的合理訪問(wèn)。要說(shuō)線程同步我們就要引入條件變量1.條件變量概念條件變量本質(zhì)上是原生線程庫(kù)提供的一個(gè)同步機(jī)制。它不是一個(gè)用來(lái)存數(shù)據(jù)的普通變量而是一個(gè)用來(lái)描述臨界資源當(dāng)前狀態(tài)的信號(hào)器。它的作用類似于消息通知讓一個(gè)線程可以掛起等待直到另一個(gè)線程改變了共享資源的狀態(tài)并通過(guò)條件變量發(fā)出資源就緒的信號(hào)來(lái)喚醒它。我們?cè)趯?xiě)搶票程序時(shí)很容易陷入一個(gè)誤區(qū)如果發(fā)現(xiàn)票賣完了線程還是會(huì)拼命去申請(qǐng)鎖、檢查、再釋放鎖循環(huán)往復(fù)這個(gè)是錯(cuò)誤的而是不應(yīng)該再申請(qǐng)鎖了而應(yīng)該等有票了再申請(qǐng)。這就像中午你想去飲水機(jī)接水走過(guò)去一看桶空了你走開(kāi)了過(guò)了兩秒你又跑過(guò)去看又空了再走開(kāi)……反復(fù)折騰。邏輯上你確實(shí)沒(méi)做錯(cuò)但這種“輪詢”不僅浪費(fèi)了你的腿腳CPU計(jì)算資源還讓本來(lái)想接水的人總要被你擋一下鎖的爭(zhēng)搶加劇。實(shí)際上更合理的做法是既然是沒(méi)水了你就應(yīng)該在飲水機(jī)旁邊貼張紙條告訴送水工水來(lái)了叫我一聲。然后你在旁邊安心休息等送水工換好新桶敲敲你的肩膀喚醒你你再去接水。這里的“紙條”或“喚醒信號(hào)”就是用來(lái)描述臨界資源狀態(tài)水有沒(méi)有的關(guān)鍵也就是我們要引入的條件變量。之所以之前我們一直在盲目地輪詢申請(qǐng)鎖根本原因就是線程之間缺乏溝通大家完全不清楚臨界資源當(dāng)前的狀況只能靠撞大運(yùn)般地去查。在張圖左邊負(fù)責(zé)“放蘋(píng)果”右邊負(fù)責(zé)“拿蘋(píng)果”中間有個(gè)盤(pán)子臨界資源。首先我們要明白放和拿的動(dòng)作是連續(xù)的如果不加控制就會(huì)出現(xiàn)二義性——萬(wàn)一我這邊還在放你那邊就來(lái)拿了誰(shuí)說(shuō)得準(zhǔn)這蘋(píng)果到底算不算已經(jīng)放好了所以鎖的作用就是強(qiáng)制規(guī)定不管你是放還是拿必須先拿鑰匙加鎖把整個(gè)過(guò)程變成不可分割的“原子操作”保證盤(pán)子里的狀態(tài)是明確的。但光有鎖還不夠。右邊有個(gè)典型的輪詢陷阱放蘋(píng)果的人手腳麻利拿蘋(píng)果的人磨磨蹭蹭。如果兩人都是瞎子互相不知道對(duì)方動(dòng)作放蘋(píng)果的人就會(huì)反復(fù)加鎖、一看蘋(píng)果還在、解鎖接著馬上又加鎖……他反反復(fù)復(fù)地瞎忙活雖然代碼沒(méi)錯(cuò)但極其浪費(fèi)CPU而行動(dòng)慢的拿蘋(píng)果的人連搶到鎖的機(jī)會(huì)都沒(méi)有陷入了“饑餓”。這時(shí)圖里紅框標(biāo)出的“鈴鐺”條件變量和旁邊的“隊(duì)列”就派上用場(chǎng)了。合理的做法是放蘋(píng)果的人加好鎖、放下蘋(píng)果解鎖后立刻敲一下鈴鐺然后去旁邊掛起睡覺(jué)。這個(gè)鈴鐺的作用就是描述當(dāng)前盤(pán)子臨界資源有沒(méi)有蘋(píng)果的狀態(tài)。另一邊拿蘋(píng)果的人并不是盲目地去搶鎖而是先在隊(duì)列等待隊(duì)列里好好排隊(duì)等著。一旦聽(tīng)到鈴鐺響他知道有蘋(píng)果了就會(huì)從隊(duì)列里被喚醒從容地去加鎖、拿走蘋(píng)果并敲鈴鐺通知對(duì)方。當(dāng)?個(gè)線程互斥地訪問(wèn)某個(gè)變量時(shí)它可能發(fā)現(xiàn)在其它線程改變狀態(tài)之前它什么也做不了。例如?個(gè)線程訪問(wèn)隊(duì)列時(shí)發(fā)現(xiàn)隊(duì)列為空它只能等待只到其它線程將?個(gè)節(jié)點(diǎn)添加到隊(duì)列中。這種情況就需要?到條件變量。2.同步概念與競(jìng)態(tài)條件同步在保證數(shù)據(jù)安全的前提下讓線程能夠按照某種特定的順序訪問(wèn)臨界資源從?有效避免饑餓問(wèn)題叫做同步競(jìng)態(tài)條件因?yàn)闀r(shí)序問(wèn)題?導(dǎo)致程序異常我們稱之為競(jìng)態(tài)條件。在線程場(chǎng)景下這種問(wèn)題也不難理解詳細(xì)內(nèi)容上一節(jié)我都講過(guò)了3.條件變量函數(shù)函數(shù)接口介紹初始化int pthread_cond_init(pthread_cond_t *restrict cond,const pthread_condattr_t *restrict attr);參數(shù)cond要初始化的條件變量attrNULL銷毀int pthread_cond_destroy(pthread_cond_t *cond)等待條件滿足pthread_cond_wait(cond, mutex)使調(diào)用線程在指定條件變量cond上阻塞并掛入其等待隊(duì)列。關(guān)鍵機(jī)制阻塞掛起的瞬間系統(tǒng)會(huì)原子性地釋放互斥鎖mutex避免死鎖當(dāng)被喚醒后系統(tǒng)又會(huì)原子性地重新獲取該鎖之后線程才得以繼續(xù)執(zhí)行后文生產(chǎn)者消費(fèi)者模型將詳細(xì)拆解。pthread_cond_timedwait(cond, mutex, abstime)接口與wait完全一致僅多出超時(shí)控制參數(shù)abstime絕對(duì)時(shí)間。若指定時(shí)間內(nèi)未收到喚醒信號(hào)線程將自動(dòng)解除阻塞。主要用于規(guī)避無(wú)限等待的風(fēng)險(xiǎn)實(shí)際應(yīng)用場(chǎng)景相對(duì)有限。參數(shù)cond要在這個(gè)條件變量上等待mutex互斥量后?詳細(xì)解釋喚醒等待pthread_cond_signal(cond)喚醒在指定條件變量cond的等待隊(duì)列中阻塞的第一個(gè)線程。常用于資源僅能滿足單個(gè)消費(fèi)者的情況。pthread_cond_broadcast(cond)喚醒所有當(dāng)前在該條件變量cond下阻塞等待的線程。多用于資源狀態(tài)發(fā)生重大變化如一次性釋放了多個(gè)資源需要通知所有等待者重新競(jìng)爭(zhēng)應(yīng)用場(chǎng)景相對(duì)較少。4.為什么 pthread_ cond_ wait 需要互斥量?條件等待是線程間同步的?種?段如果只有?個(gè)線程條件不滿??直等下去都不會(huì)滿?所以必須要有?個(gè)線程通過(guò)某些操作改變共享變量使原先不滿?的條件變得滿?并且友好的通知等待在條件變量上的線程。條件不會(huì)?緣?故的突然變得滿?了必然會(huì)牽扯到共享數(shù)據(jù)的變化。所以?定要?互斥鎖來(lái)保護(hù)。沒(méi)有互斥鎖就?法安全的獲取和修改共享數(shù)據(jù)。按照上?的說(shuō)法我們?cè)O(shè)計(jì)出如下的代碼先上鎖發(fā)現(xiàn)條件不滿?解鎖然后等待在條件變量上不就?了如下代碼:// 錯(cuò)誤示范存在致命的信號(hào)丟失風(fēng)險(xiǎn) pthread_mutex_lock(mutex); while (condition_is_false) { pthread_mutex_unlock(mutex); // 步驟1主動(dòng)解鎖 //解鎖之后等待之前條件可能已經(jīng)滿足信號(hào)已經(jīng)發(fā)出但是該信號(hào)可能被錯(cuò)過(guò) pthread_cond_wait(cond); // 步驟2此時(shí)才開(kāi)始去排隊(duì)等待 pthread_mutex_lock(mutex); // 步驟3醒來(lái)后自己搶鎖 } pthread_mutex_unlock(mutex);由于解鎖和等待不是原?操作。調(diào)?解鎖之后 pthread_cond_wait 之前如果已經(jīng)有其他線程獲取到互斥量摒棄條件滿?發(fā)送了信號(hào)那么 pthread_cond_wait 將錯(cuò)過(guò)這個(gè)信號(hào)可能會(huì)導(dǎo)致線程永遠(yuǎn)阻塞在這個(gè) pthread_cond_wait 。所以解鎖和等待必須是?個(gè)原?操作。int pthread_cond_wait(pthread_cond_ t *cond,pthread_mutex_ t *mutex); 進(jìn)?該函數(shù)后會(huì)去看條件量等于0不等于就把互斥量變成1直到cond_ wait返回把條件量改成1把互斥量恢復(fù)成原樣。5.條件變量使用規(guī)范1.等待條件代碼pthread_mutex_lock(mutex); // 必須使用 while 循環(huán)而不是 if來(lái)防止假的喚醒 while (條件為假) { pthread_cond_wait(cond, mutex); } // 此時(shí)條件為真可以安全地操作共享資源 修改條件; pthread_mutex_unlock(mutex);在這里為什么while是必須的因?yàn)榧词贡籹ignal喚醒了也可能因?yàn)橄到y(tǒng)調(diào)度或競(jìng)爭(zhēng)導(dǎo)致共享變量狀態(tài)在被喚醒的瞬間又被其他線程搶走了。使用while可以確保線程醒來(lái)后重新檢查一次如果條件又不滿足了就繼續(xù)回去等。給條件發(fā)送信號(hào)代碼pthread_mutex_lock(mutex); // 修改共享變量使等待的條件變?yōu)檎?設(shè)置條件為真; // 發(fā)出信號(hào)喚醒在 cond 上等待的一個(gè)線程 pthread_cond_signal(cond); pthread_mutex_unlock(mutex);修改條件和發(fā)送信號(hào)必須在同一個(gè)互斥鎖的保護(hù)下完成。這樣可以保證通知者寫(xiě)數(shù)據(jù)時(shí)等待者不會(huì)同時(shí)讀數(shù)據(jù)數(shù)據(jù)一致且信號(hào)不會(huì)被錯(cuò)過(guò)。代碼如下#include iostream #include string #include unistd.h #include pthread.h #define TNUM 4 typedef void (*func_t)(const std::string name,pthread_mutex_t *pmtx, pthread_cond_t *pcond); volatile bool quit false; // pthread_cond_t cond PTHREAD_COND_INITIALIZER; // pthread_mutex_t mtx PTHREAD_MUTEX_INITIALIZER; class ThreadData { public: ThreadData(const std::string name, func_t func, pthread_mutex_t *pmtx, pthread_cond_t *pcond) :name_(name), func_(func), pmtx_(pmtx), pcond_(pcond) {} public: std::string name_; func_t func_; pthread_mutex_t *pmtx_; pthread_cond_t *pcond_; }; void func1(const std::string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond) { while(!quit) { // wait一定要在加鎖和解鎖之間進(jìn)行wait pthread_mutex_lock(pmtx); pthread_cond_wait(pcond, pmtx); //默認(rèn)該線程在執(zhí)行時(shí)wait代碼被執(zhí)行當(dāng)前線程會(huì)被立即被阻塞 std::cout name running -- 播放 std::endl; pthread_mutex_unlock(pmtx); } } void func2(const std::string name,pthread_mutex_t *pmtx, pthread_cond_t *pcond) { while(!quit) { pthread_mutex_lock(pmtx); pthread_cond_wait(pcond, pmtx); if(!quit) std::cout name running -- 下載 std::endl; pthread_mutex_unlock(pmtx); } } void func3(const std::string name,pthread_mutex_t *pmtx, pthread_cond_t *pcond) { while(!quit) { pthread_mutex_lock(pmtx); pthread_cond_wait(pcond, pmtx); std::cout name running -- 刷新 std::endl; pthread_mutex_unlock(pmtx); } } void func4(const std::string name,pthread_mutex_t *pmtx, pthread_cond_t *pcond) { while(!quit) { pthread_mutex_lock(pmtx); pthread_cond_wait(pcond, pmtx); std::cout name running -- 掃碼用戶信息 std::endl; pthread_mutex_unlock(pmtx); } } void *Entry(void *args) { ThreadData *td (ThreadData*)args; // td在每一個(gè)線程自己私有的?？臻g中保存 td-func_(td-name_, td-pmtx_, td-pcond_); // 它是一個(gè)函數(shù)調(diào)用完成就要返回 delete td; return nullptr; } int main() { pthread_mutex_t mtx; pthread_cond_t cond; pthread_mutex_init(mtx, nullptr); pthread_cond_init(cond, nullptr); pthread_t tids[TNUM]; func_t funcs[TNUM] {func1, func2, func3, func4}; for (int i 0; i TNUM; i) { std::string name Thread ; name std::to_string(i1); ThreadData *td new ThreadData(name, funcs[i], mtx, cond); pthread_create(tids i, nullptr, Entry, (void*)td); } sleep(5); // ctrl new thread int cnt 10; while(cnt) { std::cout resume thread run code .... cnt-- std::endl; pthread_cond_signal(cond); // pthread_cond_broadcast(cond); sleep(1); } std::cout ctrl done std::endl; quit true; pthread_cond_broadcast(cond); for(int i 0; i TNUM; i) { pthread_join(tids[i], nullptr); std::cout thread: tids[i] quit std::endl; } pthread_mutex_destroy(mtx); pthread_cond_destroy(cond); return 0; }這段代碼主要是利用互斥鎖和條件變量實(shí)現(xiàn)線程的休眠與喚醒控制。程序啟動(dòng)之后主線程先創(chuàng)建四個(gè)子線程各個(gè)子線程運(yùn)行后就調(diào)用 pthread_cond_wait 進(jìn)入阻塞等待狀態(tài)此時(shí)線程就掛在條件變量的等待隊(duì)列上。主線程等待幾秒之后循環(huán)調(diào)用 pthread_cond_signal 每次喚醒一個(gè)子線程被喚醒的線程拿到鎖就執(zhí)行對(duì)應(yīng)的業(yè)務(wù)打印執(zhí)行完解鎖后又會(huì)再次進(jìn)入等待。等喚醒循環(huán)結(jié)束把全局退出標(biāo)記 quit 置為 true再通過(guò) pthread_cond_broadcast 喚醒所有線程讓各個(gè)子線程跳出循環(huán)正常結(jié)束最后主線程 join 回收線程資源銷毀鎖與條件變量完成整個(gè)程序的收尾。6. 條件變量的封裝基于上?的基本認(rèn)識(shí)我們已經(jīng)知道條件變量如何使?雖然細(xì)節(jié)需要后?再來(lái)進(jìn)?解釋但這?可以做?下基本的封裝#pragma once #include iostream #include string #include pthread.h #include Lock.hpp namespace CondModule { using namespace LockModule; class Cond { public: Cond() { int n pthread_cond_init(_cond, nullptr); (void)n; // 實(shí)際工程中此處應(yīng)做 n ! 0 的異常判斷或日志記錄 } void Wait(Mutex *mutex) { // 傳入底層互斥鎖的指針 int n pthread_cond_wait(_cond, mutex-GetMutexOriginal()); (void)n; } void Notify() { int n pthread_cond_signal(_cond); (void)n; } void NotifyAll() { int n pthread_cond_broadcast(_cond); (void)n; } ~Cond() { int n pthread_cond_destroy(_cond); (void)n; // 實(shí)際工程中此處應(yīng)做 n ! 0 的異常判斷或日志記錄 } private: pthread_cond_t _cond; }; }原來(lái)的 C 語(yǔ)言做法你必須在主函數(shù)里聲明pthread_cond_t cond;然后調(diào)用pthread_cond_init()初始化最后程序結(jié)束前還得記得調(diào)用pthread_cond_destroy()銷毀。一旦忘了銷毀就會(huì)造成內(nèi)存泄露。這個(gè)封裝的思路把底層的 C 變量pthread_cond_t _cond包進(jìn) C 類里。構(gòu)造函數(shù)里自動(dòng)完成初始化析構(gòu)函數(shù)里自動(dòng)完成銷毀。這就變成了只要這個(gè)類對(duì)象創(chuàng)建了條件變量就活了對(duì)象出了作用域被銷毀了條件變量也就自動(dòng)清理了。同時(shí)你不需要再手動(dòng)去操心初始化和銷毀代碼放在哪了。