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 @R_332_10586@lTask());
        
        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 @R_332_10586@lTask 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才开始后面的工作。