CyclicBarrier和CountdownLatch可以混用吗？

测试代码

public class Example {

    public static void main(String[] args) throws InterruptedException {

        final int totalThread = 10;
        CountDownLatch countDownLatch = new CountDownLatch(totalThread);
        CyclicBarrier cyclicBarrier = new CyclicBarrier(totalThread);
        ExecutorService executorService = Executors.newCachedThreadPool();
 
        for (int i = 0; i < totalThread; i++) {
            executorService.execute(() -> {
                System.out.println("run..");
                countDownLatch.countDown();
                try {
                    System.out.println("cyclicBarrierBefore..");
                    cyclicBarrier.await();
                    System.out.println("cyclicBarrierAfter..");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            });
        }
        System.out.println("countDownLatchBefore..");
        countDownLatch.await();
        System.out.println("countDownLatchAfter..");
        System.out.println("end");
        executorService.shutdown();
    }
}

运行结果

run..
run..
cyclicBarrierBefore..
run..
cyclicBarrierBefore..
run..
cyclicBarrierBefore..
run..
run..
run..
cyclicBarrierBefore..
cyclicBarrierBefore..
run..
cyclicBarrierBefore..
cyclicBarrierBefore..
countDownLatchBefore..
cyclicBarrierBefore..
run..
cyclicBarrierBefore..
run..
cyclicBarrierBefore..
countDownLatchAfter..
end
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..
cyclicBarrierAfter..

结论

两者可以混用，因为等待的不是一个同一个对象。