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í)行，并且同實例可以重復(fù)使用，而且可以通過reset方法重置狀態(tài)（調(diào)用這個方法之后，執(zhí)行await的方法的地方會拋出BrokenBarrierException異常）。
應(yīng)用場景
- 多線程計算數(shù)據(jù)，最后統(tǒng)計核算各個線程的結(jié)果
- 多線程業(yè)務(wù)中，同步節(jié)點（類似于JVM中垃圾回收章節(jié)的安全點概念）
例子
未使用回環(huán)屏障
使用回環(huán)屏障
重復(fù)使用回環(huán)屏障
實現(xiàn)原理
內(nèi)部實現(xiàn)類似與CountDownLatch，通過計數(shù)器來判斷是否繼續(xù)執(zhí)行，不過CyclicBarrier可以通過reset方法重置。所以CyclicBarrier能處理更為復(fù)雜的業(yè)務(wù)場景，一旦哪個線程計算中發(fā)生錯誤，可以通過重置計數(shù)器，并讓相關(guān)線程重新執(zhí)行。
源碼使用了ReentrantLock進行同步，如果達到最后的一個線程執(zhí)行await的話，那么index為0，會開始執(zhí)行barrierCommand的run方法。如果不是最后一個線程，就會進入循環(huán)等待的邏輯。
常見面試問題
- 是否使用過CyclicBarrier？
- CyclicBarrier的使用場景？
- CyclicBarrier的常用方法？
- 使用CyclicBarrier遇到過哪些問題，如何解決？
