一、初識CyclicBarrier

二、示例

應用場景：

在某種需求中，比如一個大型的任務，常常需要分配很多子任務去執行，只有當所有子任務都執行完成時候，才能執行主任務，這時候就可以選擇CyclicBarrier了。

示例：

package com.test;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierDemo{
    
    public static void main(String args[]) throws
 
 Exception{
        
        CyclicBarrier barrier = new CyclicBarrier(3,new TotalTask());
        
        BillTask worker1 = new BillTask("111",barrier);
        BillTask worker2 = new BillTask("222",barrier);
        BillTask worker3 = new BillTask("333",barrier);
        worker1.start();
        worker2.start();
        worker3.start();
        System.out.println(
 
"Main thread end!");
    }
    
    static class TotalTask extends Thread {
        public void run() {
            System.out.println("所有子任務都執行完了，就開始執行主任務了。");
        }
    }
    
    static class BillTask extends Thread {
        private String billName;
        private CyclicBarrier barrier;

        
 
public BillTask(String workerName,CyclicBarrier barrier) {
            this.billName = workerName;
            this.barrier = barrier;
        }

        @Override
        public void run() {
            try {
                System.out.println("市區:"+billName +"運算開始：");
                Thread.sleep(1000L);//模仿第一次運算；
                System.out.println("市區:"+billName +"運算完成，等待中...");
                barrier.await();//假設一次運算不完，第二次要依賴第一次的運算結果。都到達這個節點之後後面才會繼續執行；
                System.out.println("全部都結束，市區"+billName +"才開始後面的工作。");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }
    
}

上述程式執行結果如下：

市區:111運算開始：
市區:333運算開始：
Main thread end!
市區:222運算開始：
市區:333運算完成，等待中...
市區:222運算完成，等待中...
市區:111運算完成，等待中...
所有子任務都執行完了，就開始執行主任務了。//這句話是最後到達wait()方法的那個執行緒執行的
全部都結束，市區111才開始後面的工作。
全部都結束，市區222才開始後面的工作。
全部都結束，市區333才開始後面的工作。

解說：

A、在這個示例中，構造CyclicBarrier時，傳入了內部類TotalTask（TotalTask繼承了Thread，是Runnable的實現）的例項物件，其意義在於：當所有的執行緒都執行到wait()方法時，它們會一起返回繼續自己的工作，但是最後一個到達wait()方法的執行緒會執行TotalTask的run()方法；

B、如果在構造CyclicBarrier時沒有傳入Runnable的實現物件作為構造引數，則當所有的執行緒都執行到wait()方法時會直接一起返回繼續自己的工作。

三、詳解CyclicBarrier

（1）CyclicBarrier與CountDownLatch的區別

A、CountDownLatch的作用是允許1或N個執行緒等待其他執行緒完成執行；而CyclicBarrier則是允許N個執行緒相互等待；
B、CountDownLatch的計數器無法被重置；而CyclicBarrier的計數器可以被重置後使用，因此它被稱為是迴圈的barrier。

四、參考資料

（1）https://www.baeldung.com/java-cyclic-barrier