一、概念 闭锁是一个同步工具类,主要用于等待其他线程活动结束后,再执行后续的操作。例如:在王者荣耀游戏中,需要10名玩家都准备就绪后,游戏才能开始。 CountDownLatch是concurrent包中的一个类,是一种灵活的闭锁实现。他可以使一个或多个线程等待一组事件的发生。闭锁状态包括一个计数器,表示需要等待的数量。 ”是为了10个线程能够同时执行,如果没有“开始闭锁”,那么在循环时,前面的线程会先执行。 设置“开始闭锁”以后,10个线程均在await方法等待。当“开始闭锁”执行countDown方法时,计时器为0,10个线程的await方法同时释放,执行后续操作。 随后主线程“结束闭锁”进行await等待,由于“结束闭锁”的计数器值为10,所以10个线程都执行countDown以后,计数器值才为0,这时“结束闭锁”await方法释放,执行以下操作。
CountDownLatch实际上是一种闭锁实现。闭锁:是一种同步工具类,可以延迟线程的进度知道其到达终止状态——《Java并发编程实战》。这个怎么解释呢? 简单来说,就是有1个线程需要等待其余10个线程都执行完毕后再执行,这个时候就可以使用闭锁,也即CountDownLatch(当然闭锁的实现并不止这一种)。 import java.util.concurrent.CountDownLatch; 4 5 /** 6 * Created by yulinfeng on 12/14/16. 7 */ 8 import java.util.concurrent.CountDownLatch; 4 5 /** 6 * Created by yulinfeng on 12/14/16. 7 */ 8 import java.util.concurrent.ExecutorService; 5 import java.util.concurrent.Executors; 6 7 /** 8
闭锁的作用相当于一扇门∶ 在闭锁到达结束状态之前,这扇门一直是关闭的,并且没有任何线程能通过,当到达结束状态时,这扇门会打开并允许所有的线程通过。 当闭锁到达结束状态后,将不会再改变状态,因此这扇门将永远保持打开状态。闭锁可以用来确保某些活动直到其他活动都完成后才继续执行,例如∶ 确保某个计算在其需要的所有资源都被初始化之后才继续执行。 二元闭锁(包括两个状态)可以用来表示"资源R已经被初始化",而所有需要 R 的操作都必须先在这个闭锁上等待。 确保某个服务在其依赖的所有其他服务都已经启动之后才启动。每个服务都有一个相关的二元闭锁。 当启动服务S 时,将首先在S依赖的其他服务的闭锁上等待,在所有依赖的服务都启动后会释放闭锁S,这样其他依赖 S 的服务才能继续执行。 num.incrementAndGet())); System.out.println("cost time: " + time + "ms"); } } //输出结果 1 10 9 8
5.CountDownLatch 闭锁 需求 在多线程开发中,我们总会有一些需求处理,需要在多个线程全部执行完毕后,最后执行的。例如:统计所有线程的运行时长。 这时候就需要线程等待的操作,为了实现这个效果,下面我们来介绍一下 CountDownLatch 闭锁。 - 闭锁可以延迟线程的进度直到其到达终止状态,闭锁可以用来确保某些活动直到其他活动都完成才继续执行: - 确保某个计算在其需要的所有资源都被初始化之后才继续执行; - 确保某个服务在其依赖的所有其他服务都已经启动之后才启动 看完了基本介绍之后,我们使用 CountDownLatch 闭锁 来完成我们前面想要的效果。 并且递减闭关锁的count次数 image-20201102075156069 //定义计算偶数的线程类 class LatchDemo implements Runnable { //定义闭锁
LockTestController 类: package com.xiepanpan.locks.lockstest.controller; import com.xiepanpan.locks.lockstest.service.RedissonLockService; import org.redisson.api.RCountDownLatch; import org.redisson.api.RedissonClient; import org.springframework.beans.fac
java闭锁用于多个线程共同执行后,统一执行一个动作。比如:多个线程执行计算操作,最后汇总到同一个线程执行汇总计算。需要注意的是,java中的闭锁是仅一次的。当闭锁打开后就会统一执行下面的动作。 static void main(String[] args) throws ExecutionException, InterruptedException { /** * 闭锁
闭锁闭锁 是一种同步工具类,它可以延迟线程的进度直到其到达终止状态。 闭锁的作用相当于一扇门:在闭锁到达结束状态之前,这扇门一直是关闭的,并且没有任何线程都能通过,当到达结束状态时,这扇门会打开并允许所有的线程通过。 二元闭锁(包括两个状态)可以用来表示“资源 R 已经被初始化”,而所有需要R的操作都必须先在这个闭锁上等待。确保某个服务在其依赖的所有其他服务都已经启动之后才启动。每个服务都有一个相关的二元闭锁。 当启动服务 S 时,将首先在 S 依赖的其他服务的闭锁上等待,在所有依赖的服务都启动后会释放闭锁 S,这样其他依赖 S 的服务才能继续执行。 栅栏栅栏(Barrier) 类似于闭锁,它能阻塞一组线程直到某个事件发生。栅栏与闭锁的关键区别在于,所有线程必须同时到达栅栏位置,才能继续执行。闭锁用于等待事件,而栅栏用于等待其他线程。
许多闭锁患者可以通过有意识的眼球运动和眨眼进行交流,但也有一些患者完全不能动弹,甚至连眼球或眼睑都不能动弹,这样一来,"如果你听懂了,就眨两下眼睛"的指令就变得毫无意义。 这些方法虽然前景广阔,但通常都是侵入性的、费力的、昂贵的,专家们一致认为,要让闭锁病人发出声音,还需要进行更多的研究开发。 # 让大脑参与--但在哪里? 构建脑机接口的第一步是决定利用大脑的哪个部分。 最终,让闭锁患者恢复语言的最大挑战可能更多地与生物学有关,而不是技术。语音编码的方式,特别是内部语音,可能因个人或情况而异。
如果取消(释放)则用到了这个方法,这个方法执行一次,那么总数(构造方法中的参数count)就会减去1, 直到构造参数是0时,该管理器结束,不再闭锁其他线程。
3 import java.util.concurrent.Callable; 4 5 /** 6 * Created by yulinfeng on 12/17/16. 7 */ 8 futuretask; 2 3 import countdownlatch.TaskThread; 4 5 import java.util.concurrent.*; 6 7 /** 8 futuretask; 2 3 import countdownlatch.TaskThread; 4 5 import java.util.concurrent.*; 6 7 /** 8 其实和我们上一节将的CountDownLatch一样,它也是一种闭锁的实现。
摘要 本文主要介绍Java多线程并发中闭锁(Latch)的基本概念、原理、实例代码、应用场景,通过学习,可以掌握多线程并发时闭锁(Latch)的使用方法。 闭锁(Latch),目的是使多个线程在完成各自任务后,才会打开继续执行后面的任务,否则一直等待。 countDownLatch = new CountDownLatch(8); //将CountDownLatch对象传递到线程的run()方法中,当每个线程执行完毕run()后就将计数器减 myThread = new MyThread(countDownLatch); long start = System.currentTimeMillis(); //创建8个线程 ,并执行 for (int i = 0; i <8; i++) { new Thread(myThread).start(); } try { //主线程(main)等待:等待的计数器为
rockchip\rk356x\overlay\frameworks\base\packages\SettingsProvider\res\values\defaults.xml 在这个文件中修改 关闭锁屏
文章目录 脑图 CountDownLatch闭锁 示例 Thread#join() CountDownLatch CountDownLatch示例二 await一直等待其他线程执行完 CountDownLatch ---- CountDownLatch闭锁 Java 5.0 在 java.util.concurrent 包中提供了多种并发容器类来改进同步容器的性能。 闭锁可以延迟线程的进度直到其到达终止状态,闭锁可以用来确保某些活动直到其他活动都完成才继续执行: 确保某个计算在其需要的所有资源都被初始化之后才继续执行; 确保某个服务在其依赖的所有其他服务都已经启动之后才启动
CountDownLatch 闭锁 CountDownLatch 一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。 闭锁可以延迟线程的进度直到其达到终止状态 闭锁可以用来确保某些活动直到其他活动都完成之后才继续执行: a) 确保某个计算在其需要的所有资源都被初始化之后才继续执行; b) 确保某个服务在其依赖的所有其他服务都已经启动之后才启动 FutureTask FutureTask相信大家也不陌生了,它是一种闭锁。
CountDownLunch countDownLunch,又叫闭锁。 它有三个关键的api: new CountDownLatch(count); 创建一个闭锁,并声明count的值 countDownLatch.await();如果countDownLunch的count countDownLunch中的count减一 代码样例: Logger logger = LoggerFactory.getLogger(this.getClass()); //创建一个count=1的闭锁 = new Thread(() -> { logger.info("[{}]在等待发令枪", Thread.currentThread().getName()); try { //等待闭锁的
从火箭发场景来学习Java多线程并发闭锁对象 倒计时器场景 在我们开发过程中,有时候会使用到倒计时计数器。最简单的是:int size = 5; 执行后,size—这种方式来实现。 然后再闭锁上等待的其他线程就可以恢复正常工作了。
CountDownLatch也常常被我们称为闭锁,是JUC提供给我们算是比较常用的一个工具了。 当计数器值到达0时,它表示所有的线程已经完成了任务,然后在闭锁上等待的线程就可以恢复执行任务。 使用场景: 实现最大并行性:注意不是并发,是并行。并行强调的是所有人同一时刻统一开始。 Java8提供了基于流式处理的类似功能类:Completablefuture,推荐使用。 具体参考我之前的博文:【小家java】Java8新特性之—CompletableFuture的系统讲解和实例演示(使用CompletableFuture构建异步应用) 缺点 构造器中的计数值(count )实际上就是闭锁需要等待的线程数量。
闭锁:CountDownLatch 1.1 使用场景 若有多条线程,其中一条线程需要等到其他所有线程准备完所需的资源后才能运行,这样的情况可以使用闭锁。 1.2 代码实现 // 初始化闭锁,并设置资源个数 CountDownLatch latch = new CountDownLatch(2); Thread t1 = new Thread( new Runnable(){ public void run(){ // 加载资源1 加载资源的代码…… // 本资源加载完后,闭锁-1 Thread( new Runnable(){ public void run(){ // 加载资源2 资源加载代码…… // 本资源加载完后,闭锁 2.2 闭锁 与 同步屏障 的区别 闭锁只会阻塞一条线程,目的是为了让该条任务线程满足条件后执行; 而同步屏障会阻塞所有线程,目的是为了让所有线程同时执行(实际上并不会同时执行,而是尽量把线程启动的时间间隔降为最少
同步工具类图: 闭锁相关:CountDownLatch 信号量相关:Semaphore 栅栏相关:CyclicBarrier 、Exchanger 线程池相关:Executors 闭锁 闭锁是一种工具同步类 闭锁的作用相当于一道门,在闭锁到达结束状态之前,这扇门一直是关闭的,没有线程可以通过;当闭锁结束时,这扇门会打开所有线程可以通过。当闭锁达到结束状态打开门时,将不会再改变其状态,即门不会再次关闭。 CountDownLatch是一种灵活的闭锁实现,可以在上述各种情况下使用,它可以使一个或多个线程等待一组事件的发生。闭锁状态包括一个计数器,计数器被初始化为一个正数,表示需要等待的事件数量。 如果不适用闭锁,先启动的线程必将领先后启动的线程。 信号量Semaphore 计数信号量用来控制同时访问某个特定资源的操作数量,或者同时指定某个特定操作的数量。 栅栏与闭锁的关键区别在于,所有线程必须同时到达栅栏位置,才能继续执行。闭锁用于等待事件,栅栏用于等待其他线程。 常见的栅栏有两种形式:CyclicBarrier和Exchanger。
这几款微机保护装置主要通过以下保护功能实现对高压柜的设备运行情况实时监视和保护: 1)AM5-F线路保护装置 三段式过流保护(可经低电压闭锁、可带方向闭锁)、反时限过流保护(可经低电压闭锁)、两段式零序 )、PT断线告警、控故障告警、FC回路配合的过流闭锁功能、非电量保护、逆功率保护、零序过压跳闸、零序过压告警、过电压跳闸、过电压告警、二次谐波闭锁 2)AM3SE-I电流型保护装置 三段式过流保护(可经低电压闭锁 、可经二次谐波闭锁)、反时限过流保护(可经低电压闭锁)、过负荷告警/跳闸、三段式零序I01过流/反时限过流保护、三段式零序I02过流/反时限过流保护、FC回路配合的过流闭锁功能、控故障告警、零序过压告警 配电工程所设微机保护型号与数量如下: 开关柜编号微机保护装置型号微机保护装置数量1#变电站G1AM3SE-I1台G2AM3SE-I1台G3AM5SE-UB1台G5AM3SE-I1台G6AM3SE-I1台G7AM3SE-I1台G8AM3SE-I1 变电站1AH5AM3SE-I1台1AH6AM3SE-I1台3#变电站2AH1AM3SE-I1台2AH2AM3SE-I1台2AH5AM3SE-I1台2AH6AM3SE-I1台2AH7AM3SE-I1台2AH8AM3SE-I1