Java 柵欄 CyclicBarrier 介紹

1、類說明：

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

2、使用場景：

需要所有的子任務都完成時，才執行主任務，這個時候就可以選擇使用cyclicbarrier。

3、常用方法：

public intawait()
throws interruptedexception,
brokenbarrierexception

在所有參與者都已經在此 barrier 上呼叫 await方法之前，將一直等待。如果當前執行緒不是將到達的最後乙個執行緒，出於排程目的，將禁用它，且在發生以下情況之一前，該執行緒將一直處於休眠狀態：

如果當前執行緒：

則丟擲interruptedexception，或者在呼叫 await 時 barrier 被損壞，抑或任意乙個執行緒正處於等待狀態，則丟擲brokenbarrierexception異常。

如果任何執行緒在等待時被中斷，則其他所有等待執行緒都將丟擲brokenbarrierexception異常，並將 barrier 置於損壞狀態。

如果當前執行緒是最後乙個將要到達的執行緒，並且構造方法中提供了乙個非空的屏障操作，則在允許其他執行緒繼續執行之前，當前執行緒將執行該操作。如果在執行屏障操作過程中發生異常，則該異常將傳播到當前執行緒中，並將 barrier 置於損壞狀態。

返回：

到達的當前執行緒的索引，其中，索引getparties()- 1 指示將到達的第乙個執行緒，零指示最後乙個到達的執行緒

丟擲：

interruptedexception- 如果當前執行緒在等待時被中斷

brokenbarrierexception- 如果另乙個執行緒在當前執行緒等待時被中斷或超時，或者重置了 barrier，或者在呼叫await時 barrier 被損壞，抑或由於異常而導致屏障操作（如果存在）失敗。

4、相關例項

賽跑時，等待所有人都準備好時，才起跑：

public class cyclicbarriertest 
}class runner implements runnable 
@override
public void run()  catch (interruptedexception e)  catch (brokenbarrierexception e) 
system.out.println(name + " 起跑！");
}}

結果：

1號選手準備好了... 2號選手準備好了... 3號選手準備好了... 3號選手起跑！ 1號選手起跑！

2號選手起跑！

Java 柵欄 CyclicBarrier 介紹

LintCode 柵欄染色

514 柵欄染色

USACO Overfencing 穿越柵欄

Java 柵欄 CyclicBarrier 介紹

LintCode 柵欄染色

514 柵欄染色

USACO Overfencing 穿越柵欄

相關推薦