CountDownLatch

，Java高并发编程的三大基本工具之一，什么是CountDownLatchCountDownLatch是通过一个计数器实现的，计数器的初始值为线程数。每执行一个线程，计数器的值就减1，当计数器的值为0时，说明所有线程都执行完了，然后等待锁上的线程（调用await方法的线程）可以复工。应用场景CountDownLatch可以用来做什么？有哪些应用场景？在实际项目中有没有应用场景？这应该是每个人都关心的。我们先来看看官网提供的例子是如何应用的https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html官方提供了两个demo我直接put已经转换成图片了。顺便推荐一下这段代码转换图片的网址https://www.dute.org/code-snapshot，蛮好用的。官方网站demo1第一个是启动信号，在司机准备好让他们继续之前，阻止任何工人继续前进；第二个是完成信号，允许驱动程序等待所有工作人员完成。”第一个开始信号（startSignal）将阻止任何工人（worker）在司机到达之前开始工作。说白了，司机不来，工人就无法工作。第二个是完成信号（doneSignal），它允许驱动程序等待直到所有工人都完成。说白了就是司机要等到所有工人都做完了。官网demo2另一种典型的用法是将一个问题分成N个部分，用一个执行该部分的Runnable来描述每个部分并在latch上倒计时，并将所有Runnables排队到一个Executor。当所有子部分完成后，协调线程才能通过await。”另一个典型的用法是将一个大任务拆分成N个部分，让多个线程（Worker）执行，每个线程（Worker）执行自己的部分计数器减1即可，当所有子部分完成后，Driver会继续往下执行。就像富士康手机加工的流水线一样，一部手机的装配需要一系列的流水线配合每条流水线（Worker），每条线各司其职。有的线在贴膜，有的在拧螺丝，有的在质检，有的在充电，有的在贴膜。这些线都是干的时候大功告成，一部手机就组装完成了，上面两个是官方提供的demo，接下来说两个我们平时开发中可以用到的栗子：多线程等待：模拟并发，让并发线程一起执行。有时我们写了一个接口，想测试一下，看看它的最大并发数是多少。当然我们可以使用Jmeter进行压测，但是有时候不想下载工具，其实可以使用CountDownLatch来实现。/***@author:公众号：javafinance*/publicclassTestCountDownLatch1{publicstaticvoidmain(String[]args)throwsInterruptedException{CountDownLatchcountDownLatch=newCountDownLatch(1);for(inti=0;i<5;i++){newThread(()->{try{//这里阻塞所有请求，等待countDownLatch.await();//调用测试接口System.out.println(Thread.currentThread().getName()+"开始执行...");}catch(InterruptedExceptione){e.printStackTrace();}}).start();}//让请求准备好Thread.sleep(2000);//让所有请求统一请求countDownLatch.countDown();}}我们使用CountDownLatch.await()让多个参与线程在启动后阻塞等待，然后在主线程调用CountDownLatch.countdown()将计数减为0，让所有线程一起执行；从而实现多个线程同时并发执行，模拟并发请求的目的。单线程等待：多线程（任务）完成后聚合合并count);for(inti=0;i{try{Thread.sleep(1000+ThreadLocalRandom.current().nextInt(1000));System.out.println("finish"+index+Thread.currentThread().getName());}catch(InterruptedExceptione){e.printStackTrace();}finally{countDownLatch.countDown();}}).start();}countDownLatch.await();//主线程阻塞，当计数器==0时，唤醒主线程继续执行。System.out.println("主线程：所有任务完成后，汇总结果");}}这种场景应该用的最多。比如我们打开一个电商个人中心页面，需要调用，用户信息接口，用户订单接口，用户会员信息等接口组合起来一起发送给前端。假设每个接口最长耗时为1s。如果我们同步调用的话，最大耗时是3s。如果我们使用异步调用然后合并结果，那么最大耗时是3s。每次接口调用返回数据后，调用countDown方法将计数器减1，当计数器减到0时，线程会唤醒主线程，让它继续往下走。CountDownLatch实现原理CountDownLatch是通过AQS的state字段实现的计数器。计数器的初始值（state的值）是newCountDownLatch设置的数。每调用一次countDown，state的值就会减1。最后，当一个线程将state值减为0时，就会唤醒调用await()的线程阻塞等待。CountDownLatch重写了tryReleaseShared方法。只有当state字段设置为0，即tryReleaseShared返回true时，doReleaseShared方法才会被执行，唤醒调用await的线程。publicfinalbooleanreleaseShared(intarg){if(tryReleaseShared(arg)){doReleaseShared();returntrue;}returnfalse;}rotectedbooleantryReleaseShared(intarg){//Decrementcount;signalwhentransitiontozerofor(;;){intc=getState();if(c==0)returnfalse;intnextc=c-1;if(compareAndSetState(c,nextc))returnextc==0;}}CountDownLatch其他源码就不分析了，相信看完这两篇文章?,《Java高并发编程基础三大利器之Semaphore》再来看到这个还是比较容易的。总结CountDownLatch不能重新初始化或修改CountDownLatch内部计数器的值。CountDownLatch和Semaphore在AQS的使用方式上非常相似。在同步状态下，保存当前计数值。CountDownLatch的作用是让一个或多个线程等待其他线程完成操作。它看起来有点类似于join()方法，但它提供了比join()更灵活的API。CountDownLatch可以手动控制在n个线程中调用n次countDown()方法使计数器减一，也可以在一个线程中调用n次执行减一操作。join()的实现原理是不断检查join线程是否存活，如果join线程存活，则当前线程会一直等待。因此，CountDownLatch在两者之间使用起来相对更加灵活。本文转载自微信公众号“java财经”，可通过以下二维码关注。转载本文请联系爪哇财经公众号。