public class CyclicBarrierSimple {

    public static void main(String[] args) {
        int N = 4;
        /**
         * partie：在达到删栏时 指定的线程数被阻塞等待...
         * barrierAction:到达删栏时 执行的线程任务
         */
        CyclicBarrier barrier = new CyclicBarrier(N,new ThreadRunner());
        for (int i = 0; i < N; i++) {
            new Writer(barrier).start();
        }
        try {
            Thread.sleep(25000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("CyclicBarrier重用");

        for(int i=0;i<N;i++) {
            new Writer(barrier).start();
        }
    }

    static class ThreadRunner implements Runnable{

        @Override
        public void run() {
            System.out.println("大家统一到达删栏后执行...");
        }
    }

    static class Writer extends Thread {

        private CyclicBarrier cyclicBarrier;

        public Writer(CyclicBarrier barrier) {
            cyclicBarrier = barrier;
        }

        @Override
        public void run() {
            System.out.println(System.currentTimeMillis() + "线程" + Thread.currentThread().getName() + " 正在写入数据...");
            try {
                //以睡眠来模拟写入数据库操作
                TimeUnit.MILLISECONDS.sleep(1000);
                System.out.println("线程" + Thread.currentThread().getName() + "写入数据完毕,等待其他线程写入完毕");
                int index = cyclicBarrier.await();
                System.out.println("越过栅栏后的索引" + index);
            } catch (InterruptedException | BrokenBarrierException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "所有线程写入完毕，继续处理其他任务");

        }
    }
}