关于CyclicBarrier与CountDownLatch使用场景的探讨

浅浅的花香味﹌ 2023-02-17 01:27 34阅读 0赞

点击上方“码农进阶之路”，选择“设为星标”

回复“面经”获取面试资料

![format_png][]

来源：网络

![format_png 1][]

**前言**

首先我们先针对于上一节讲的给出一个很重要的区别:

CountDownLatch 很明显是可以不限制等待线程的数量，而会限制 countDown的操作数。

CyclicBarrier 会限制等待线程的数量。

![format_png 1][]

**实战**

我们来看JDK给我们带来的两种用法:

class Driver { // ...
      void main() throws InterruptedException {
        CountDownLatch startSignal = new CountDownLatch(1);
        CountDownLatch doneSignal = new CountDownLatch(N);
      
        for (int i = 0; i < N; ++i) // create and start threads
          new Thread(new Worker(startSignal, doneSignal)).start();
      
        doSomethingElse();            // don't let run yet <1>
        startSignal.countDown();      // let all threads proceed <2>
        doSomethingElse();            // <3>
        doneSignal.await();           // wait for all to finish <4>
      }
    }
      
    class Worker implements Runnable {
      private final CountDownLatch startSignal;
      private final CountDownLatch doneSignal;
      Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
        this.startSignal = startSignal;
        this.doneSignal = doneSignal;
      }
      public void run() {
        try {
          startSignal.await(); // <5>
          doWork();
          doneSignal.countDown();
        } catch (InterruptedException ex) {} // return;
      }
      
      void doWork() { ... }
    }}

‍这里其实就是在传达信息，首先，这里定义了一个所传状态值为1的 startSignal和状态值为N的 doneSignal，然后通过for循环起了N个线程执行任务，但是在这些线程执行具体任务之前我主线程里有一波逻辑必须先行(因为有些变量的设定是子线程里共享的东西)，那么，我就可以在其内进行 startSignal.await()的设定，可以看到，我这里N可以是很大的一个数字，这也就是我们上面讲的 CountDownLatch的一个很强的特性的应用。

接着，在我主线程的一波先行逻辑执行完后(请看<1>)，我就可以放行，于是就可以调用<2>处的 startSignal.countDown()，对各个线程进行解除挂起，这里<3>处的代码就和各个子线程里的任务没有什么冲突，也就没什么happen-before这种要求限定了，但我们其他线程就有担心你主线程执行完我任务没完成怎么办，使用sleep？我执行完主线程可能还在等待，这个时间真的不确定，那就在主线程里使用<4>处的代码 doneSignal.await()。

这样，当我各个子线程都结束的时候，我就可以做到主线程在第一时间也可以结束掉省的浪费资源了，这里，有童鞋可能会说主线程里也可以调用XxxThread.join()，但要注意的是，当一个线程调用之后，主线程就休眠了，剩下的join()操作也就无从谈起了，也就是说其他线程结束的时候会调用一下 this.notifyAll但仅针对于这个要结束的线程，所以主线程可能会经历休眠启动，再休眠，再启动，这就浪费性能了。

我们接着看JDK给我们提供的第二个常用使用场景例子:

class Driver2 { // ...
       void main() throws InterruptedException {
        CountDownLatch doneSignal = new CountDownLatch(N);
         Executor e = ...
    
    
         for (int i = 0; i < N; ++i) // create and start threads
           e.execute(new WorkerRunnable(doneSignal, i));
    
    
         doneSignal.await();           // wait for all to finish
       }
     }
    
    
     class WorkerRunnable implements Runnable {
       private final CountDownLatch doneSignal;
       private final int i;
       WorkerRunnable(CountDownLatch doneSignal, int i) {
         this.doneSignal = doneSignal;
         this.i = i;
       }
       public void run() {
         try {
           doWork(i);
           doneSignal.countDown();
        } catch (InterruptedException ex) {} // return;
       }
    
    
       void doWork() { ... }
     }}

‍这里就实现了一个分治算法应用，首先，我们可以将要做的工作进行策略分割，也就是 doWork()方法实现，里面可以根据所传参数进行策略执行，因为任务要放到线程中执行，而且这里还涉及到了一个策略分配，往往，我们的任务在大局上可以很快的进行策略分块操作。

然后，每一个块内我们可以根据情况假如复杂再进行一个forkJoin的一个应用，这里我们无须去考虑那么多，我们通过实现一个 Runnable来适配Thread需求。

这里，为了适应子线程和主线程的等待执行关系，使用了CountDownLatch来实现，通过上一个例子，大家应该很清楚了，主线程传入一个定义的 CountDownLatch对象，子线程调用，在其 Runnable.run方法的最后调用 doneSignal.countDown()。主线程在其最后调用 doneSignal.await()，这都是固定套路，记住就好。

最后，在 doWork()中根据策略得到的任务很复杂的话，就可以使用 forkJoin策略进行二次分治了，这样就可以做到，分模块，有计算型的模块，也有IO型的模块，而且这些模块彼此不影响，每个模块内部的话可能会有共享数据的情况，就需要根据并发的其他知识进行解决了，这里就不多讲了，具体情况具体分析。

![format_png 2][]

往期精选

[2019秋招：460道Java后端面试高频题答案版【模块一：Java基础】][2019_460_Java_Java]

[2019秋招：460道Java后端面试高频题答案版【模块二：Java集合类】][2019_460_Java_Java 1]

[2019秋招：460道Java后端面试高频题答案版【模块三：Java并发】][2019_460_Java_Java 2]

[2019秋招：460道Java后端面试高频题答案版【模块四：Java虚拟机】][2019_460_Java_Java 3]

[2019秋招：460道Java后端面试高频题答案版【模块五：计算机网络】][2019_460_Java]

[2019秋招：460道Java后端面试高频题答案版【模块六：计算机操作系统】][2019_460_Java 1]

[2019秋招：460道Java后端面试高频题答案版【模块七：设计模式】][2019_460_Java 2]

[面试题：讲讲Redis有哪几个过期策略？][Redis]

[工具篇：这可能是全 GitHub 最牛逼的抢票神器！][GitHub]

码农进阶之路

长按二维码关注

![format_png 3][]

面经 | 原理 | 源码 | 实战 | 工具

![format_png 4][]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9XNERDcWp0cWVhdjZENEo5aWFjUVhiWGVBZGwwQkQ3Sk1IdUwxU1hBQ3pGbnBqWHFncUxiemhvYjl4akJramtqVG82U1NkT3FyQmd2Q1ZTR2o0Y0xycVEvNjQw?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2dpZi9XNERDcWp0cWVhdXh6dVRYb1BkMXhrbkxRM2JGUUtVTTJzRGU5OG1CVDFmTDhpYks0aWNxaWNpYXNNSGdEQndpY1JRbU50cVAwUGVHRnBlUUExSEU0V3dwSzNnLzY0MA?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2dpZi82YVZhT045S2liZjdjaWM5VWM1dHBJNjhKb0pxQ2QxRFJsRmlibWp0M2t6eXAzM1ZxMEtjaWJQRXBLYUNjeFhZY054OXBPbDU5d29CdGlhNmVVTGdvRnJQSERBLzY0MA?x-oss-process=image/format,png
[2019_460_Java_Java]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&idx=1&mid=2247484494&scene=21&sn=1e5f782e60a8d983ea256b4d4b603049#wechat_redirect
[2019_460_Java_Java 1]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&idx=1&mid=2247484495&scene=21&sn=d561aa0679f203aae9fd2561cdd796ca#wechat_redirect
[2019_460_Java_Java 2]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&idx=1&mid=2247484496&scene=21&sn=27c84ebb4b7d86e7fa48a3d158c42bd5#wechat_redirect
[2019_460_Java_Java 3]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd1143caca66cadc3bc7777299bfaee4b92e73850af275ce51a87f43e390e762fbb6b4f0fe48&idx=1&lang=zh_CN&mid=2247484498&scene=21&sn=98cfe73ccb25b48f597f6ae388bf5e25&token=628438799#wechat_redirect
[2019_460_Java]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd1143c1ca66cad7e846f780b178d59af6aad9cc80bf476b24e7e937386bbcbd2b56cfba7325&idx=1&lang=zh_CN&mid=2247484505&scene=21&sn=e29c828758f3801091e9f2f0cb2769a6&token=628438799#wechat_redirect
[2019_460_Java 1]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd1143c2ca66cad424704a5d7469660c86c3ffd252a1aeea327d63cfcbd0ed20d3016ce4860a&idx=1&lang=zh_CN&mid=2247484506&scene=21&sn=b0709b16632ec30fde025e2db409f4e6&token=628438799#wechat_redirect
[2019_460_Java 2]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd1143c3ca66cad53abf3390ccfd33278a44ee49ae77d06ef6f8d416bd24e9d9ae04ed31a27e&idx=1&lang=zh_CN&mid=2247484507&scene=21&sn=99c5fa753f44f3926457c151ed2d6089&token=1855460459#wechat_redirect
[Redis]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd11445fca66cd49107ec49753cc2e7e9bbab02e56bacf0a725b5b2858b21dc41835dd2625d0&idx=1&lang=zh_CN&mid=2247484359&scene=21&sn=9450e4c7eb488e62c1e43b3e3c532caa&token=1831305316#wechat_redirect
[GitHub]: https://mp.weixin.qq.com/s?__biz=MzU3NjY4ODg4Nw%3D%3D&chksm=fd1144e0ca66cdf6f258a582d03818be6fe3f746ce1fbba67d18edc43ce84db4697d56469368&idx=1&lang=zh_CN&mid=2247484280&scene=21&sn=529c0b4256e64e00a2aae92568cce173&token=388083482#wechat_redirect
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9XNERDcWp0cWVhdXh6dVRYb1BkMXhrbkxRM2JGUUtVTXNtaWJxRzJFcFBnNWpiOTY2YUhOeDNRSnZjSHVhemFpYTRpY1d4TTZqUDlpYTZaczdvaWJ0bDJFa0lnLzY0MA?x-oss-process=image/format,png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iOTZDaWJDdDcwaWFhQkFpY0ROQ1NzNkgwTzBTQkdTQUxmbmljTlRrcWE1VDZZWTZhbTM0NmhkcGpsTlZ0clpSTUVkZGg2QktSSW1TaWNYSkhQVWhrYTR4amJnLzY0MA?x-oss-process=image/format,png