一，介紹

?CyclicBarrier是一個保持多個線程共享同一個狀態的工具類。

也就是說在多線程環境下，能夠通過設定某一個狀態來達到線程之間的同步。這個類有兩個有參構造方法。各自是CyclicBarrier(int n)和CyclicBarrier(int n, Runnable r)。第一個構造方法的意思是指給這個類設置等待點到多少時才運行在run方法中調用await方法之後的操作；第二個構造器的Runnable能夠看作一個等待點的狼煙，狼煙是什麽，是一種信號。也就是說，在等待線程達到n這個數量之後，會開始運行run方法中調用await方法之後的代碼，而在調用這些代碼前，會先放狼煙，然後再運行那些代碼。

這個類在多線程統計數據時還是非常實用的。可是要註意，假設你的線程數量總是達不到設置的n的數量，那麽這時，操作將被堵塞，即await方法後面的代碼總是不能運行。

二，樣例

package test;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrrierTest {
    static int count = 0;
    
    static List<Integer> data= Collections.synchronizedList(new ArrayList<Integer>());
    public static void main(String[] args) {
        //設置2個等待線程，存在兩個等待線程時，計算集合中的何，然後再清除集合中的數據
        CyclicBarrier cb = new CyclicBarrier(2, new Runnable() {
            public void run() {
                int sum = 0;
                for(int i = 0; i < data.size(); i++) {
                    sum += data.get(i);
                }
                System.out.println("current sum is " + sum);
                data.clear();
            }
        });
        int n = 10;
        for(int i =0 ; i< n; i++) {
            new Thread(new CBThread(2, cb,data)).start();  //開啟n個線程
        }
    }

}

class CBThread implements Runnable{
    private int n;
    private CyclicBarrier cb;
    private List<Integer> data;
    public CBThread(int n,CyclicBarrier cb,List<Integer> data) {
        this.n = n;
        this.cb = cb;
        this.data = data;
    }
    
    public void run() {
        Random random = new Random();
//        while(!done()) {  
            int n = random.nextInt(10);
            data.add(n);
            System.out.println(Thread.currentThread().getName() + " ======" + n + ",  " + cb.getNumberWaiting());
            try {
                cb.await();  //await方法後面的代碼總是在cb.getNumberWait等於n的時候才運行
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
            System.out.println("走起......" + CyclicBarrrierTest.count);
//        }
    }
    
    private boolean done() {
        return false;
    }
}

CyclicBarrier分析與實例