CyclicBarrier的作用

CyclicBarrier循环栅栏和CountDownLatch很类似，都能阻塞—组线程。
当有大量线程相互配合，分别计算不同任务，并且需要最后统一汇总的时候，我们可以使用CyclicBarrier。CyclicBarrier可以构造一个集结点，当某一个线程执行完毕，它就会到集结点等待，直到所有线程都到了集结点，那么该栅栏就被撤销，所有线程再统一出发，继续执行剩下的任务。

CyclicBarrier 和 CountDownLatch的区别

作用不同: CyclicBarrier要等固定数量的线程都到达了栅栏位置才能继续执行,而CountDownLatch只需等待数字到0,也就是说 CountDownLatch用于事件,但是CyclicBarrier是用于线程的。
可重用性不同: CountDownLatch在倒数到0并触发门门打开后,就不能再次使用了,除非新建新的实例;而CyclicBarrier可以重复使用。

    /**
     * 景区游船满载为六个人, 当前有30个人要乘船, 他们依次排队坐船, 满六人就先发船
     */
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(6);
        CyclicBarrier cyclicBarrier = new CyclicBarrier(6, () -> {
            System.out.println("船上人员已满, 游船开始出发 ...");
        });

        for (int i = 0; i < 30; i++) {
            executorService.submit(new Task(i+ 1,cyclicBarrier));
        }
        executorService.shutdown();
    }

    static class Task implements Runnable{
        /**
         * 游客序号
         */
        private Integer num;

        private CyclicBarrier cyclicBarrier;

        public Task(Integer num, CyclicBarrier cyclicBarrier) {
            this.num = num;
            this.cyclicBarrier = cyclicBarrier;
        }

        @Override
        public void run() {
            try {
                Thread.sleep(RandomUtils.nextInt(2,6) * 1000);
                System.out.print(num + " ok,");
                cyclicBarrier.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }