循环栅栏，用来进行线程协作，等待线程满足某个计数。构造时设置『计数个数』，每个线程执行到某个需要“同步”的时刻调用 await() 方法进行等待，当等待的线程数满足『计数个数』时，继续执行

ExecutorService service = Executors.newFixedThreadPool(2);
        CyclicBarrier barrier = new CyclicBarrier(2,()->{
            log.debug("task1 task2 finish...");
        });

        service.submit(()->{
            log.debug("task1 begin……");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            try{
                barrier.await();
                log.debug("task1 end……");
            }catch (InterruptedException | BrokenBarrierException e){
                e.printStackTrace();
            }
        });
        service.submit(()->{
            log.debug("task2 begin……");
            try {
                Thread.sleep(2000);
                log.debug("task2 end……");
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            try{
                barrier.await();
            }catch (InterruptedException | BrokenBarrierException e){
                e.printStackTrace();
            }
        });

注意 CyclicBarrier 与 CountDownLatch 的主要区别在于 CyclicBarrier 是可以重用的 CyclicBarrier 可以被比
喻为人满发车

注意：
使用我们的CyclicBarrier ，要是我们的线程池中的线程数和CyclicBarrier 的数量大小一样才能发挥CyclicBarrier 的人满发车效果。