CountDownLatch和CyclicBarrier到底有什么区别

Bertha 。 2023-03-02 04:53 72阅读 0赞

CountDownLatch和CyclicBarrier在进行多线程编程时会见到，通常CountDownLatch在业务中会用的多点，我们先来看下CountDownLatch和CyclicBarrier的2个小例子：

*  CountDownLatch 测试代码

public class CountDownLatchTest {
        static ExecutorService pool = Executors.newFixedThreadPool(3);
        public static void main(String[] args) {
            countDownLatch();
        }
        static void countDownLatch() {
            long t1 = System.currentTimeMillis();
            int count = 3;
            CountDownLatch latch = new CountDownLatch(count);
            for (int i = 1; i <= count; i++) {
                int finalI = i;
                pool.execute(new Runnable() {
                    @Override
                    public void run() {
                        System.out.println(finalI + ":run");
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        } finally {
                            latch.countDown();
                        }
                    }
                });
            }
            try {
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            long t2 = System.currentTimeMillis();
            System.out.println("耗时：" + (t2 - t1) + "ms");
            System.out.println("main");
        }
    }

*  CountDownLatch测试的运行结果：

![20200911111959780.png][]

从上图的运行结果中可以看到CountDownLatch主要的作用是**等待子线程执行完成后，主线程再继续往下走.**

*  CyclicBarrier测试代码

public class CyclicBarrierTest {
        static ExecutorService pool = Executors.newFixedThreadPool(10);
    
        public static void main(String[] args) {
            cyclicBarrier();
        }
    
        static void cyclicBarrier() {
            long t1 = System.currentTimeMillis();
            int count = 3;
            CyclicBarrier barrier = new CyclicBarrier(count, () -> {
                long t2 = System.currentTimeMillis();
                System.out.println("耗时：" + (t2 - t1) + "ms");
            });
            for (int i = 1; i <= count; i++) {
                int finalI = i;
                pool.execute(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            System.out.println(finalI + ":run");
                            Thread.sleep(1000);
                            barrier.await();
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                });
            }
            System.out.println("main");
        }
    }

*  CyclicBarrier测试的运行结果

![20200911115338434.png][]

![20200911134013683.png][]

从上图中可以看到，虽然主线程执行的顺序不一样，但是耗时一定是最后执行的。

通过上面的2个小例子，我们可以知道**假设有一个接口需要知道多线程任务执行完成花了多长时间，直接使用CyclicBarrier就可以异步打印出多线程任务的耗时时间。**

以前总觉得CountDownLatch和CyclicBarrier没什么区别，都是等子线程执行完了之后再执行后续的逻辑。但是区别就是CountDownLatch后续的逻辑只能由主线程完成，而CyclicBarrier后续的逻辑是由子线程完成的。也就是说CountDownLatch在做子线程运行完成之后的任务时，必须是同步完成的；而CyclicBarrier是可以异步完成的。

### **总结：** ###

总的来说，CyclicBarrier相对于CountDownLatch就是可以**异步处理多线程任务的运行结果**，比如多线程的耗时时间、线程任务的运行结果的汇总和统计，以及数据合并等都可以使用CyclicBarrier。

[20200911111959780.png]: /images/20230208/024a77af1b5e46c68384ef5437598ec8.png
[20200911115338434.png]: /images/20230208/8f76a1d8a3ca410cbe7b84e790aa1b3c.png
[20200911134013683.png]: /images/20230208/d8298d66629f49049162a4e19565de0f.png