Java并發(fā)工具包——CyclicBarrier
回顧
上一期Java并發(fā)工具包跟大家聊了下CountDownLatch,大家一定記得它的使用場景曙咽,那么這期繼續(xù)給大家說下Java并發(fā)工具中的常用工具——CyclicBarrier到千,這個工具類的使用場景跟CountDownLatch類似埠戳,下面跟大家展開說說。
簡介
通過類的名稱就可以了解一些
- Cyclic——循環(huán)、回環(huán)
- Barrier——柵欄恢总、屏障
CyclicBarrier就是環(huán)形屏障,那么具體是什么意思呢睬愤?
很簡單片仿,其實就是等待所有回環(huán)屏障中的線程都執(zhí)行到指定位置,才能夠繼續(xù)執(zhí)行尤辱。具體實際的例子就是遠途大巴車車滿發(fā)車砂豌。結(jié)合CountDownLatch來看的話就比較簡單了厢岂,CountDownLatch是若干線程等待所有工作的子線程,CyclicBarrier是若干線程等待阳距,所有線程執(zhí)行完成之后塔粒,再繼續(xù)執(zhí)行,并且同實例可以重復使用筐摘,而且可以通過reset方法重置狀態(tài)(調(diào)用這個方法之后卒茬,執(zhí)行await的方法的地方會拋出BrokenBarrierException異常)。
應用場景
- 多線程計算數(shù)據(jù)咖熟,最后統(tǒng)計核算各個線程的結(jié)果
- 多線程業(yè)務中圃酵,同步節(jié)點(類似于JVM中垃圾回收章節(jié)的安全點概念)
例子
未使用回環(huán)屏障
使用回環(huán)屏障
重復使用回環(huán)屏障
實現(xiàn)原理
內(nèi)部實現(xiàn)類似與CountDownLatch,通過計數(shù)器來判斷是否繼續(xù)執(zhí)行馍管,不過CyclicBarrier可以通過reset方法重置郭赐。所以CyclicBarrier能處理更為復雜的業(yè)務場景,一旦哪個線程計算中發(fā)生錯誤确沸,可以通過重置計數(shù)器捌锭,并讓相關線程重新執(zhí)行。
源碼使用了ReentrantLock進行同步罗捎,如果達到最后的一個線程執(zhí)行await的話舀锨,那么index為0,會開始執(zhí)行barrierCommand的run方法宛逗。如果不是最后一個線程坎匿,就會進入循環(huán)等待的邏輯。
常見面試問題
- 是否使用過CyclicBarrier雷激?
- CyclicBarrier的使用場景替蔬?
- CyclicBarrier的常用方法?
- 使用CyclicBarrier遇到過哪些問題屎暇,如何解決承桥?