Java之CountDownLatch原理全面解析

更新时间：2022年10月28日 09:13:24 作者：阿拉的梦想

这篇文章主要介绍了Java之CountDownLatch原理解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

CountDownLatch原理解析

1. demo展示

代码逻辑展示了主线程中创建2个子线程分别去执行任务，主线程等2个子线程执行完毕后，再接着执行下面的代码；

常用场景：

分别计算，汇总结果。如，多个线程分别解析excel中的sheet,等待全部解析完毕后汇总结果；

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class CountDownLatchDemo {
    //定义一个倒计时闩锁
    static CountDownLatch c = new CountDownLatch(2);

    public static void main(String[] args) throws InterruptedException {
        new Thread(() -> {
            try {
                TimeUnit.MICROSECONDS.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("我是线程1");
            //释放一个
            c.countDown();
        }).start();

        new Thread(() -> {
            try {
                TimeUnit.MICROSECONDS.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("我是线程2");
            //释放一个
            c.countDown();
        }).start();

        System.out.println("我是主线程，我要等那两个线程执行完毕...");
        //等待倒计时为0
        c.await();
        System.out.println("我是主线程,那两个线程都执行完了");
    }
}

输出：

我是主线程，我要等那两个线程执行完毕...

我是线程2

我是线程1

我是主线程,那两个线程都执行完了

2. 原理解析

1.先看构造函数new CountDownLatch(2)做了什么？

这是初始化了AQS子类，并将AQS的状态state设置为传入的2；

public CountDownLatch(int count) {
      if (count < 0) throw new IllegalArgumentException("count < 0");
      this.sync = new Sync(count);
  }

2.看c.countDown()做了什么？

它释放了一个共享锁状态，也就是state减1；

public void countDown() {
     sync.releaseShared(1);
 }

3.再看c.await()做了什么？

await方法是CounDownLatch中定义的，它调用了其内部类Sync（也是AQS的子类）的获取共享锁的方法acquireSharedInterruptibly；

acquireSharedInterruptibly方法中调用了CountDownLatch内部类Sync中实现的获取共享锁的方法tryAcquireShared，返回值不小0就算获取到了锁，await方法就能返回了，如果返回值小于0将会进入阻塞等待;

CountDownLatch内部类Sync中tryAcquireShared的实现很简单，只要state=0就返回1，否则返回-1；上面说了返回一个不小于0的数字，c.await()就相当于获取到了锁，就可以返回了，主线程就可以继续执行了。

通过上面分析，每次c.countDown(),就会将state减1，state=0的时候主线程恢复执行；

Java CountDownLatch学习总结

来源包

同为 java.util.concurrent 下的，即也是并发多线程相关下的类，直译 “倒计时锁存器”，一般用于多线程场景，单一的线程也可以，用于等待多个任务完成后再执行其他操作；

提供方法

await()

导致当前线程等待，直到锁存器倒数到零，除非该线程是｛@linkplain Thread35;interrupt interrupted｝即被打断状态。
如果当前计数为零，则此方法立即返回。
如果当前计数大于零，则当前线程将出于线程调度目的被禁用，并处于休眠状态，直到发生以下两种情况之一：
由于调用{@link#countDown}方法，计数达到零；或者其他线程{@linkplain thread#中断}当前线程。

如果当前线程：

在进入此方法时设置了其中断状态；或者
在等待时{@linkplain Thread#interrupt interrupted}，
则抛出{@link InterruptedException}，并清除当前线程的中断状态。

简单说就是当使用了这个方法后当前这一个线程将进入等待状态，直到计数器被减到0或者当前线程被中断，计数器被减到0后，所有等待的线程将被唤醒继续向下执行

await(long timeout, TimeUnit unit)

同上，但是指定了等待的超时时间，即线程除了上方两种被唤醒的情况下，等待到超时时间后也会被唤醒

countDown()：当前计数器减一，如果如果减到 0 则唤醒所有等待在这个 CountDownLatch 上的线程。
getCount()：获取当前计数的数值

业务书写示例

即将需要一会儿处理的业务 list 设置为计数器的大小，

然后对里面的业务数据执行异步操作，处理业务过程中不论是否有异常都需要对计数器减一，最终使用 await 等待所有任务执行完成，执行完成后，将进入后续处理

            final CountDownLatch latch = new CountDownLatch(lists.size());
            
            for (List<JSONObject> item: lists) {
                executor.submit(new Runnable() {
                    @Override
                    public void run() {
                        // ....... 业务处理
                        } catch (Exception e) {
                            // 异常处理
                        } finally {
                            latch.countDown();
                        }
                    }
                });
            }

            try {
                latch.await();
            } catch (InterruptedException e) {
                log.error("线程被中断", e);
            }

       // lists 处理完成后的其他业务操作

一般代码示例

public static void main(String[] args) throws InterruptedException {
        final CountDownLatch downLatch = new CountDownLatch(3);

        Await wait111 = new Await("wait111", downLatch);
        Await wait222 = new Await("wait222", downLatch);
        CountDownStart countDownStart = new CountDownStart(downLatch);

        wait111.start();
        wait222.start();
        Thread.sleep(1000);
        countDownStart.run();

    }


class Await extends Thread{

    private CountDownLatch countDownLatch;
    private String name;

    public Await(String name, CountDownLatch countDownLatch){
        this.name = name;
        this.countDownLatch = countDownLatch;
    }


    @Override
    public void run() {
        System.out.println(name + " start.....");
        System.out.println(name + " run.....");
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(name + " continue.....run");
    }
}

class CountDownStart extends Thread{

    private CountDownLatch countDownLatch;

    public CountDownStart(CountDownLatch countDownLatch){
        this.countDownLatch = countDownLatch;
    }

    @Override
    public void run() {
        countDownLatch.countDown();
        countDownLatch.countDown();
        countDownLatch.countDown();
        System.out.println("start countDown");
    }
}

运行结果：

wait222 start.....
wait222 run.....
wait111 start.....
wait111 run.....
start countDown
wait111 continue.....run
wait222 continue.....run

但是当我把线程等待去除后：

    public static void main(String[] args) throws InterruptedException {
        final CountDownLatch downLatch = new CountDownLatch(3);

        Await wait111 = new Await("wait111", downLatch);
        Await wait222 = new Await("wait222", downLatch);
        CountDownStart countDownStart = new CountDownStart(downLatch);

        wait111.start();
        wait222.start();
//        Thread.sleep(1000);
        countDownStart.run();

    }

结果：

start countDown
wait111 start.....
wait111 run.....
wait111 continue.....run
wait222 start.....
wait222 run.....
wait222 continue.....run

另外两个线程线程并没有开始就执行，可能被抢占了，也可能调度优先度不同，实际使用时还是需要多多实验

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

MyBatisPlus代码生成器的原理及实现详解
这篇文章主要为大家详细介绍了MyBatisPlus中代码生成器的原理及实现，文中的示例代码讲解详细，对我们学习MyBatisPlus有一定帮助，需要的可以参考一下
2022-08-08
基于Java实现Actor模型
Actor模型是一种常见的并发模型，与最常见的并发模型—共享内存（同步锁）不同，它将程序分为许多独立的计算单元—Actor，文中有详细的代码示例，感兴趣的同学可以参考阅读
2023-05-05
解决cmd运行java程序“找不到文件”提示的方案
在本篇文章里小编给大家分享的是关于解决cmd运行java程序“找不到文件”提示的方案，有需要的朋友们可以参考下。
2020-02-02
最新log4j2远程代码执行漏洞(附解决方法)
Apache Log4j2 远程代码执行漏洞攻击代码，该漏洞利用无需特殊配置，经多方验证，Apache Struts2、Apache Solr、Apache Druid、Apache Flink等均受影响,本文就介绍一下解决方法
2021-12-12
Spring注解中@Configuration和@Component到底有啥区别
之前一直搞不清@Component和@Configuration这两个注解到底有啥区别,一直认为被这两修饰的类可以被Spring实例化嘛,最近终于弄明白了,这篇文章主要给大家介绍了关于Spring注解中@Configuration和@Component到底有啥区别的相关资料,需要的朋友可以参考下
2023-04-04
springmvc无法访问/WEB-INF/views下的jsp的解决方法
本篇文章主要介绍了springmvc无法访问/WEB-INF/views下的jsp的解决方法，非常具有实用价值，需要的朋友可以参考下
2017-10-10
Mybatis批量插入大量数据的最优方式总结
批量插入功能是我们日常工作中比较常见的业务功能之一,下面这篇文章主要给大家总结介绍了关于Mybatis批量插入大量数据的几种最优方式,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-03-03
深入理解Java中观察者模式与委托的对比
这篇文章主要介绍了Java中观察者模式与委托的对比,观察者模式：定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象，委托的实现简单来讲就是用反射来实现的，本文给大家介绍的非常详细，需要的朋友可以参考下
2022-05-05
java 算法 6种排序小结
这篇文章主要介绍了java 算法 6种排序,排序原理及实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-10-10
java开发中常遇到的各种难点以及解决思路方案
Java项目是一个复杂的软件开发过程,其中会涉及到很多技术难点,这篇文章主要给大家介绍了关于java开发中常遇到的各种难点以及解决思路方案的相关资料,需要的朋友可以参考下
2023-07-07