CyclicBarrier允許一組執行緒互相等待，直到到達某個公共屏障點。如果你希望一組並行的任務在下個步驟之前相互等待，直到所有的任務都完成了下個步驟前的所有操作，才繼續向前執行，那麼CyclicBarrier很合適。

函式列表

//構造方法摘要
CyclicBarrier(int parties) 
          //建立一個新的 CyclicBarrier，它將在給定數量的參與者（執行緒）處於等待狀態時啟動，但它不會在啟動 barrier 時執行預定義的操作。
CyclicBarrier(int parties, Runnable barrierAction) 
          //建立一個新的 CyclicBarrier，它將在給定數量的參與者（執行緒）處於等待狀態時啟動，並在啟動 barrier 時執行給定的屏障操作，該操作由最後一個進入 barrier 的執行緒執行。  
 

//方法摘要
 int    await() 
          //在所有參與者都已經在此 barrier 上呼叫 await 方法之前，將一直等待。
 int    await(long timeout, TimeUnit unit) 
          //在所有參與者都已經在此屏障上呼叫 await 方法之前將一直等待,或者超出了指定的等待時間。
 int    getNumberWaiting() 
          //返回當前在屏障處等待的參與者數目。
 int    getParties() 
          //返回要求啟動此 barrier 的參與者數目。
 boolean    isBroken() 
          //查詢此屏障是否處於損壞狀態。
 

 void   reset() 
          //將屏障重置為其初始狀態。

CyclicBarrier與CountDownLatch的比較
看過CyclicBarrier的方法列表後，有沒有發現CyclicBarrier與CountDownLatch比較像。它們之間最大的區別在於CyclicBarrier的計數器可以重置，相當於可以迴圈使用。cyclic，意為可迴圈的，barrier，意為屏障，剛好映照了CyclicBarrier的兩個特點。

例項1：CyclicBarrier簡單使用

public class CyclicBarrierTest {
    // 參與者數量
    private
 
 static int parties = 3;
    // 建立一個新的 CyclicBarrier，它將在給定數量的參與者（執行緒）處於等待狀態時啟動
    private static CyclicBarrier barrier = new CyclicBarrier(parties);
    public static void main(String[] args) throws InterruptedException {
        for (int i = 0; i < parties; i++)
            new Thread(new Task()).start();
        Thread.sleep(1000);
        System.out.println("getNumberWaiting()：" + barrier.getNumberWaiting());
    }

    static class Task implements Runnable {
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + "await");
                // 在所有參與者都已經在此 barrier 上呼叫 await 方法之前，將一直等待。
                barrier.await();
                System.out.println(Thread.currentThread().getName() + "continued");
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

執行結果為：
Thread-0await
Thread-1await
Thread-2await
Thread-1continued
Thread-0continued
Thread-2continued
getNumberWaiting()：0

從結果中可以看到，3個任務執行緒依次啟動，但每一個都沒有執行完，這是因為run方法中的cb.await();使當前執行緒在所有參與者都已經在此barrier上呼叫await方法之前，一直等待。直到所有的參與者都已經在此barrier上呼叫await，才執行所有等待的任務。
從最後一行輸出可以看出，在所有執行緒越過屏障後，當前在屏障處等待的參與者數目變為0。

原始碼

待補充

本文就講到這裡，想了解Java併發程式設計更多內容請參考：