九 java多執行緒之CyclicBarrier

github:

乙個同步輔助類，它允許一組執行緒互相等待，直到到達某個公共屏障點 (common barrier point)。在涉及一組固定大小的執行緒的程式中，這些執行緒必須不時地互相等待，此時 cyclicbarrier 很有用。因為該 barrier 在釋放等待執行緒後可以重用，所以稱它為迴圈的 barrier。

cyclicbarrier 支援乙個可選的 runnable 命令，在一組執行緒中的最後乙個執行緒到達之後（但在釋放所有執行緒之前），該命令只在每個屏障點執行一次。若在繼續所有參與執行緒之前更新共享狀態，此屏障操作很有用。

示例用法：下面是乙個在並行分解設計中使用 barrier 的例子：

class solver

public void run() catch (interruptedexception ex) catch (brokenbarrierexception ex) }}

}public solver(float matrix)

});for (int i = 0; i < n; ++i)

new thread(new worker(i)).start();

waituntildone();

}

在這個例子中，每個 worker 執行緒處理矩陣的一行，在處理完所有的行之前，該執行緒將一直在屏障處等待。處理完所有的行之後，將執行所提供的 runnable 屏障操作，並合併這些行。如果合併者確定已經找到了乙個解決方案，那麼 done() 將返回 true，所有的 worker 執行緒都將終止。

如果屏障操作在執行時不依賴於正掛起的執行緒，則執行緒組中的任何執行緒在獲得釋放時都能執行該操作。為方便此操作，每次呼叫 await() 都將返回能到達屏障處的執行緒的索引。然後，您可以選擇哪個執行緒應該執行屏障操作，例如：

if (barrier.await() == 0)

對於失敗的同步嘗試，cyclicbarrier 使用了一種要麼全部要麼全不 (all-or-none) 的破壞模式：如果因為中斷、失敗或者超時等原因，導致執行緒過早地離開了屏障點，那麼在該屏障點等待的其他所有執行緒也將通過 brokenbarrierexception（如果它們幾乎同時被中斷，則用 interruptedexception）以反常的方式離開。

還是一樣,理論是比較枯燥的,咱們還是舉例來說,比較生動一點.一些教科書舉一些1~100000分批累加例子.咱們不舉這種比較無聊的例子.旅遊,相信很多人都喜歡吧!旅遊的套路一般都出發點集合,入住酒店,到旅遊點1,再到旅遊點2,再到旅遊點3,在集合返回.每次都某乙個地點時.導遊都會清點人數.不要把人給弄丟.ok,開始編碼...

public class tourismrunnable implements runnable
@override
public void run() 
/*** 旅遊過程
*/private void tourism() 
/*** 裝備返程
*/private void gotoendpoint() 
/*** 到達旅遊點3
*/private void gototourismpoint3() 
/*** 到達旅遊點2
*/private void gototourismpoint2() 
/*** 到達旅遊點1
*/private void gototourismpoint1() 
/*** 入住酒店
*/private void gotohotel() 
/*** 出發點集合
*/private void gotostartingpoint() 
private int getrandomtime() catch (interruptedexception e) 
return time;
}private void gotopoint(string point) catch (exception e) }}

在每個旅遊點,每個人旅遊所花的時間是隨機的,有些人玩的比較久一點,有些則走馬觀花,拍拍照就完事了

public class testmain 
});listtourismthread = new arraylist<>();
for (char ch : name.tochararray())
for (thread thread : tourismthread)}}

執行結果:

小剛花了 131 時間才到了出發點小黑花了 237 時間才到了出發點小麗花了 250 時間才到了出發點小紅花了 335 時間才到了出發點小明花了 379 時間才到了出發點小白花了 398 時間才到了出發點小白清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go.... 小紅花了 128 時間才到了酒店小剛花了 156 時間才到了酒店小黑花了 240 時間才到了酒店小白花了 280 時間才到了酒店小明花了 492 時間才到了酒店小麗花了 499 時間才到了酒店小麗清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go.... 小麗花了 188 時間才到了旅遊點1 小剛花了 315 時間才到了旅遊點1 小明花了 374 時間才到了旅遊點1 小白花了 395 時間才到了旅遊點1 小黑花了 428 時間才到了旅遊點1 小紅花了 496 時間才到了旅遊點1 小紅清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go.... 小明花了 206 時間才到了旅遊點2 小剛花了 223 時間才到了旅遊點2 小紅花了 302 時間才到了旅遊點2 小白花了 308 時間才到了旅遊點2 小黑花了 317 時間才到了旅遊點2 小麗花了 400 時間才到了旅遊點2 小麗清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go.... 小白花了 100 時間才到了旅遊點3 小麗花了 132 時間才到了旅遊點3 小紅花了 157 時間才到了旅遊點3 小黑花了 165 時間才到了旅遊點3 小剛花了 375 時間才到了旅遊點3 小明花了 416 時間才到了旅遊點3 小明清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go.... 小剛花了 100 時間才到了飛機場,準備登機回家小黑花了 137 時間才到了飛機場,準備登機回家小紅花了 232 時間才到了飛機場,準備登機回家小明花了 260 時間才到了飛機場,準備登機回家小麗花了 264 時間才到了飛機場,準備登機回家小白花了 394 時間才到了飛機場,準備登機回家小白清點人數,1,2,3...,ok,人到齊了,準備出發..... go go go....

ok, 執行結果一目了然,中途沒有落下任何乙個人!cyclicbarrier這個類,還是比較容易使用的

九 java多執行緒之CyclicBarrier

JAVA多執行緒之執行緒池

Java多執行緒之執行緒安全

java 多執行緒之 Excutor

九 java多執行緒之CyclicBarrier

JAVA多執行緒之 執行緒池

Java多執行緒之執行緒安全

java 多執行緒 之 Excutor

相關推薦

JAVA多執行緒之執行緒池

java 多執行緒之 Excutor