CyclicBarrier 的字面意思是可循環使用（Cyclic）的屏障（Barrier）。它要做的事情是，讓一組線程到達一個屏障（也可以叫同步點）時被阻塞，直到最後一個線程到達屏障時，屏障才會開門，所有被屏障攔截的線程才會繼續幹活。CyclicBarrier默認的構造方法是

CyclicBarrier(int parties)，其參數表示屏障攔截的線程數量，每個線程調用await方法告訴CyclicBarrier我已經到達了屏障，然後當前線程被阻塞。

cBarrierTest {

    public static void main(String[] args) {
        ExecutorService service 
 
= Executors.newCachedThreadPool();
        final CyclicBarrier cb = new CyclicBarrier(3);//約定三個人同時到達
        for (int i = 0; i < 3; i++) {
            Runnable runnable = new Runnable() {
                public void run() {
                    try {
                        Thread.sleep((long) (Math.random() * 10000));
                        System.out.println(
 
"線程" + Thread.currentThread().getName() +
                                "即將到達集合地點1，當前已有" + (cb.getNumberWaiting() + 1) + "個已經到達，" + (cb.getNumberWaiting() == 2 ? "都到齊了，繼續走啊" : "正在等候"));
                        cb.await();//三個同時線程的時候才往下走

                        Thread.sleep((long) (Math.random() * 10000));
                        System.out.println(
 
"線程" + Thread.currentThread().getName() +
                                "即將到達集合地點2，當前已有" + (cb.getNumberWaiting() + 1) + "個已經到達，" + (cb.getNumberWaiting() == 2 ? "都到齊了，繼續走啊" : "正在等候"));
                        cb.await();
                        Thread.sleep((long) (Math.random() * 10000));
                        System.out.println("線程" + Thread.currentThread().getName() +
                                "即將到達集合地點3，當前已有" + (cb.getNumberWaiting() + 1) + "個已經到達，" + (cb.getNumberWaiting() == 2 ? "都到齊了，繼續走啊" : "正在等候"));
                        cb.await();
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            service.execute(runnable);
        }
        service.shutdown();
    }
}

java並發之同步輔助類