當(dāng)前位置:首頁 > 公眾號精選 > CPP開發(fā)者
[導(dǎo)讀]之前整理過一篇C20新特性的文章全網(wǎng)首發(fā)!!C20新特性全在這一張圖里了,里面提到過latch、barrier和semaphore,但是沒有詳細介紹過三者的作用和區(qū)別,這里詳細介紹下。latch這個可能大多數(shù)人都有所了解,這就是我們經(jīng)常會用到的CountDownLatch。用于使...

之前整理過一篇C 20新特性的文章全網(wǎng)首發(fā)??!C 20新特性全在這一張圖里了,里面提到過latch、barrier和semaphore,但是沒有詳細介紹過三者的作用和區(qū)別,這里詳細介紹下。

latch

這個可能大多數(shù)人都有所了解,這就是我們經(jīng)常會用到的CountDownLatch。用于使一個線程先阻塞,等待其他線程完成各自的工作后再繼續(xù)執(zhí)行。

CountDownLatch是通過計數(shù)器實現(xiàn),計數(shù)器的初始值為線程的數(shù)量。每當(dāng)一個線程完成了自己的任務(wù)后,計數(shù)器的值就會減1。當(dāng)計數(shù)器值到達0時,它表示所有的線程已經(jīng)完成了任務(wù),然后等待的線程就可以打斷阻塞去繼續(xù)執(zhí)行任務(wù)。

自己之前實現(xiàn)過一個CountDownLatch,源碼大概這樣:

CountDownLatch::CountDownLatch(int32_t?count)?:?count_(count)?{}

void?CountDownLatch::CountDown()?{??
????std::unique_lock?lock(mutex_);????
????--count_;????
????if?(count_?==?0)?{???????
????????cv_.notify_all();???
????}
}
void?CountDownLatch::Await(int32_t?time_ms)?{???
????std::unique_lock?lock(mutex_);????
????while?(count_?>?0)?{???????
????????if?(time_ms?>?0)?{????????
????????????cv_.wait_for(lock,?std::chrono::milliseconds(time_ms));???????
????????}?else?{???????????
????????????cv_.wait(lock);???????
????????}???
????}
}

int32_t?CountDownLatch::GetCount()?const?{???
????std::unique_lock?lock(mutex_);?
????return?count_;
}

barrier

許多線程在阻塞點阻塞,當(dāng)?shù)竭_阻塞點的線程達到一定數(shù)量時,會執(zhí)行完成的回調(diào),然后解除所有相關(guān)線程的阻塞,然后重置線程計數(shù)器,繼續(xù)開始下一階段的阻塞。

假設(shè)有很多線程并發(fā)執(zhí)行,并在一個循環(huán)中執(zhí)行一些計算。進一步假設(shè)一旦這些計算完成,需要在線程開始其循環(huán)的新迭代之前對結(jié)果進行一些處理。

看以下示例代碼(摘自cppreference):

#include?
#include?
#include?
#include?
#include??

int?main()?{??
??const?auto?workers?=?{?"anil",?"busara",?"carl"?};???
??
??auto?on_completion?=?[]()?noexcept?{????
????//?locking?not?needed?here????
????static?auto?phase?=?"...?done\n"?"Cleaning?up...\n";????
????std::cout?<????phase?=?"...?done\n";??
??};??
??std::barrier?sync_point(std::ssize(workers),?on_completion);??
??
??auto?work?=?[
本站聲明: 本文章由作者或相關(guān)機構(gòu)授權(quán)發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內(nèi)容真實性等。需要轉(zhuǎn)載請聯(lián)系該專欄作者,如若文章內(nèi)容侵犯您的權(quán)益,請及時聯(lián)系本站刪除。
關(guān)閉
關(guān)閉