摘要:今天我们来聊一聊的使用场景。使用场景在某些业务情况下,要求我们等某个条件或者任务完成后才可以继续处理后续任务。同时在线程完成时也会触发一定事件。方便业务继续向下执行。第个毒贩如果当前已经没有可以毒贩,立刻返回被干掉了干掉一个。
作者 : 毕来生前言
微信: 878799579
在 java.util.concurrent 包中提供了多种并发容器类来改进同步容器 的性能。今天我们来聊一聊CountDownLatch 的使用场景。看看它到底是怎么玩耍的。
CountDownLatch 是干什么的? CountDownLatch 一个同步辅助类,在完成一组正在其他线程中执行的操作 之前,它允许一个或多个线程一直等待。
CountDownLatch原理 CountDownLatch是通过一个计数器来实现的,计数器的初始化值为线程的数量。每当一个线程完成了自己的任务后,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已完成任务,然后在闭锁上等待的线程就可以恢复执行任务。
使用场景 在某些业务情况下,要求我们等某个条件或者任务完成后才可以继续处理后续任务。同时在线程完成时也会触发一定事件。方便业务继续向下执行。这个时候我们的CountDownLatch就隆重登场啦。常用核心方法为
/** * 递减计数器的计数,如果计数达到0,则释放所有等待的线程。 * 如果当前计数大于0,则将计数减少。 * 如果新的计数为0,会重启所有等待线程 * 如果当前计数等于0,则不做任何操作 **/ public void countDown() { sync.releaseShared(1); } /** * 1、当前线程在倒数至0之前会一直等待 * 2、除非线程被中断或超出了指定的时间。 * 3、如果当前计数为0,立刻返回为true * 4、如果当前计数等于0,则不做任何操作 * 5、如果当前线程在进入此方法时已经设置了该线程的中断状态, * 或者在等待时被中断,则抛出InterruptedException **/ public boolean await(long timeout, TimeUnit unit) throws InterruptedException { return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); }实战演练
package org.bilaisheng.juc; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * @Author: bilaisheng * @Wechat: 878799579 * @Date: 2019/1/2 23:30 * @Todo: CountDownLatch demo。 * @Version : JDK11 , IDEA2018 */ public class CountDownLatchTest { // 举个例子:有十个毒贩在和警察激战 public static void main(String[] args) throws InterruptedException { // 开始计数器 final CountDownLatch start = new CountDownLatch(1); // 结束计数器 final CountDownLatch end = new CountDownLatch(10); final ExecutorService executorService = Executors.newFixedThreadPool(10); for (int i = 1; i <= 10; i++) { // 这个变量纯粹为了掩饰到底哪个倒霉先被干掉。 final String criminal = "第"+i+"个毒贩"; Runnable task = new Runnable() { @Override public void run() { try { // 如果当前已经没有可以毒贩,立刻返回 start.await(); Thread.sleep(500); System.out.println(criminal + "被干掉了!"); } catch (InterruptedException e) { e.printStackTrace(); } finally { // 干掉一个。毒贩活着的数量就减1 end.countDown(); } } }; executorService.submit(task); } // 抓捕开始 start.countDown(); // 全都被干掉了(计数器为0) end.await(); // 任务完成:收工回家 executorService.shutdown(); } }
闭锁可以延迟线程的进度直到其到达终止状态,闭锁可以用来确保某些活动直到其他活动都完成才继续执行:
确保某个计算在其需要的所有资源都被初始化之后才继续执行;
确保某个服务在其依赖的所有其他服务都已经启动之后才启动;
等待直到某个操作所有参与者都准备就绪再继续执行。
喜欢就关注我吧文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/75765.html
摘要:表示的是两个,当其中任意一个计算完并发编程之是线程安全并且高效的,在并发编程中经常可见它的使用,在开始分析它的高并发实现机制前,先讲讲废话,看看它是如何被引入的。电商秒杀和抢购,是两个比较典型的互联网高并发场景。 干货:深度剖析分布式搜索引擎设计 分布式,高可用,和机器学习一样,最近几年被提及得最多的名词,听名字多牛逼,来,我们一步一步来击破前两个名词,今天我们首先来说说分布式。 探究...
摘要:一导语最近在学习并发编程原理,所以准备整理一下自己学到的知识,先写一篇的源码分析,之后希望可以慢慢写完整个并发编程。了解了的构造函数之后,我们再来看它的核心代码,首先是。 一、导语 最近在学习并发编程原理,所以准备整理一下自己学到的知识,先写一篇CountDownLatch的源码分析,之后希望可以慢慢写完整个并发编程。 二、什么是CountDownLatch CountDownLatc...
摘要:所以得出结论需要分配较多的线程进行读数据,较少的线程进行写数据。注意多线程编程对实际环境和需求有很大的依赖,需要根据实际的需求情况对各个参数做调整。 背景 最近对于 Java 多线程做了一段时间的学习,笔者一直认为,学习东西就是要应用到实际的业务需求中的。否则要么无法深入理解,要么硬生生地套用技术只是达到炫技的效果。 不过笔者仍旧认为自己对于多线程掌握不够熟练,不敢轻易应用到生产代码中...
阅读 2261·2021-11-24 09:39
阅读 2511·2021-11-22 15:24
阅读 2944·2021-09-02 09:48
阅读 2976·2021-07-26 22:01
阅读 1406·2019-08-30 11:09
阅读 1644·2019-08-29 18:47
阅读 566·2019-08-29 15:40
阅读 2105·2019-08-29 15:22