一、类介绍
java.util.concurrent类CountDownLatch
public class CountDownLatch extends Object
一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。给定一个数来初始化CountDownLatch,这个值即需要等待的操作数。当某个线程需要等待一组操作时,通过调用await方法进行阻塞。某个操作完成,通过调用countDown方法使计数器减一。在该计数值到达0之前,调用await()方法的线程会一直等待。之后会释放所有等待的线程,await的后续调用将立即返回。该计数值无法被重置,即只能被初始化一次。
二、使用场景
-
将计数 1 初始化的 CountDownLatch 用作一个简单的开/关锁存器,或入口:在通过调用 countDown() 的线程打开入口前,所有调用 await 的线程都一直在入口处等待;
-
用 N 初始化的 CountDownLatch 可以使一个线程在 N 个线程完成某项操作之前一直等待,或者使其在某项操作完成 N 次之前一直等待。
三、使用实例
1.等待者和任务者,一群等待者线程等待一群任务者线程完成任务。使用Countdownlatch控制等待者们等待,直到所有的任务者都完成它们的任务后,等待者才能执行。
package concurrent; import java.util.concurrent.*; import java.util.*; import static net.mindview.util.Print.*; // Performs some portion of a task: class TaskPortion implements Runnable { private static int counter = 0; private final int id = counter++; private static Random rand = new Random(47); private final CountDownLatch latch; TaskPortion(CountDownLatch latch) { this.latch = latch; } public void run() { try { doWork(); latch.countDown(); } catch (InterruptedException ex) { // Acceptable way to exit } } public void doWork() throws InterruptedException { TimeUnit.MILLISECONDS.sleep(rand.nextInt(2000)); print(this + "completed"); } public String toString() { return String.format("%1$-3d ", id); } } // Waits on the CountDownLatch: class WaitingTask implements Runnable { private static int counter = 0; private final int id = counter++; private final CountDownLatch latch; WaitingTask(CountDownLatch latch) { this.latch = latch; } public void run() { try { latch.await(); print("Latch barrier passed for " + this); } catch (InterruptedException ex) { print(this + " interrupted"); } } public String toString() { return String.format("WaitingTask %1$-3d ", id); } } public class CountDownLatchDemo { static final int SIZE = 10; public static void main(String[] args) throws Exception { ExecutorService exec = Executors.newCachedThreadPool(); // All must share a single CountDownLatch object: CountDownLatch latch = new CountDownLatch(SIZE); for (int i = 0; i < 5; i++) exec.execute(new WaitingTask(latch)); /*创建100个任务线程,共享一个count为100的CountDownLatch,每个线程完成任务后执行countdown将count-1,直到count为0时, * 即所有的线程都完成了任务,等待线程才能执行,因此,CountDownLatch可以很方便的等待一组线程完成任务*/ for (int i = 0; i < SIZE; i++) exec.execute(new TaskPortion(latch)); print("Launched all tasks"); exec.shutdown(); // Quit when all tasks complete } } /* (Execute to see output) */// :~
上面的例子中创建了5个等待者线程和10个任务者线程。创建了一个初始值为10的CountdownLatch,5个等待者共享这个CountDownLatch,意思是他们共同等待一些操作,操作的个数为10.在每个操作中调用countDown()。所以10个任务者线程也共享这个CountDownLatch,每个线程完成任务后都调用了countDown,否则等待者们会一直等待。(注意:初始计数值的大小和任务者线程数要相同)
输出:
Launched all tasks 7 completed 8 completed 5 completed 9 completed 0 completed 3 completed 6 completed 4 completed 1 completed 2 completed Latch barrier passed for WaitingTask 0 Latch barrier passed for WaitingTask 2 Latch barrier passed for WaitingTask 4 Latch barrier passed for WaitingTask 1 Latch barrier passed for WaitingTask 3
2.跑步比赛,所有的Player都必须等待听到枪响声后才能起跑。
package concurrent; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; class Player implements Runnable{ private CountDownLatch latch ; public Player(CountDownLatch l) { // TODO Auto-generated constructor stub this.latch = l; } @Override public void run() { // TODO Auto-generated method stub try { latch.await(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + " start to run!"); } } class Guner implements Runnable{ private CountDownLatch latch ; public Guner(CountDownLatch latch) { super(); this.latch = latch; } @Override public void run() { // TODO Auto-generated method stub for(int i = 0;i < 3;i++){ System.out.println(3-i); } System.out.println("Bong!"); latch.countDown(); } } public class CountDownLatchTest2 { public static void main(String[] args) { // TODO Auto-generated method stub CountDownLatch latch = new CountDownLatch(1); ExecutorService exec = Executors.newCachedThreadPool(); for(int i = 0;i < 8;i++){ exec.execute(new Player(latch)); } exec.execute(new Guner(latch)); } }
输出:
3 2 1 Bong! pool-1-thread-1 start to run! pool-1-thread-3 start to run! pool-1-thread-8 start to run! pool-1-thread-2 start to run! pool-1-thread-4 start to run! pool-1-thread-5 start to run! pool-1-thread-6 start to run! pool-1-thread-7 start to run!
三、重要方法
await public void await() throws InterruptedException 使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断。 如果当前计数为零,则此方法立即返回。 如果当前计数大于零,则出于线程调度目的,将禁用当前线程,且在发生以下两种情况之一前,该线程将一直处于休眠状态: 由于调用 countDown() 方法,计数到达零;或者 其他某个线程中断当前线程。 如果当前线程: 在进入此方法时已经设置了该线程的中断状态;或者 在等待时被中断, 则抛出 InterruptedException,并且清除当前线程的已中断状态。 抛出: InterruptedException - 如果当前线程在等待时被中断
await public boolean await(long timeout, TimeUnit unit) throws InterruptedException 使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断或超出了指定的等待时间。 如果当前计数为零,则此方法立刻返回 true 值。 如果当前计数大于零,则出于线程调度目的,将禁用当前线程,且在发生以下三种情况之一前,该线程将一直处于休眠状态: 由于调用 countDown() 方法,计数到达零;或者 其他某个线程中断当前线程;或者 已超出指定的等待时间。 如果计数到达零,则该方法返回 true 值。 如果当前线程: 在进入此方法时已经设置了该线程的中断状态;或者 在等待时被中断, 则抛出 InterruptedException,并且清除当前线程的已中断状态。 如果超出了指定的等待时间,则返回值为 false。如果该时间小于等于零,则此方法根本不会等待。 参数: timeout - 要等待的最长时间 unit - timeout 参数的时间单位。 返回: 如果计数到达零,则返回 true;如果在计数到达零之前超过了等待时间,则返回 false 抛出: InterruptedException - 如果当前线程在等待时被中断
countDown public void countDown() 递减锁存器的计数,如果计数到达零,则释放所有等待的线程。 如果当前计数大于零,则将计数减少。如果新的计数为零,出于线程调度目的,将重新启用所有的等待线程。 如果当前计数等于零,则不发生任何操作。
相关推荐
本文将对CountDownLatch和CyclicBarrier的使用场景和实现进行详细的介绍。 CountDownLatch的应用场景: CountDownLatch是一个非常有用的线程控制工具,它可以使一个线程等待其他线程达到某一目标后进行自己的下...
本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始化时设定一个初始值,通常表示一个任务的子任务数量。每个线程完成其工作后会调用`countDown()`方法,...
本文将详细介绍如何利用MyBatis结合多线程和CountDownLatch闭锁来实现数据的批量插入。 首先,我们来看`mybatis批处理`。MyBatis的批处理功能允许我们在一次数据库连接中执行多条SQL语句,从而减少了数据库连接的...
下面我们将详细介绍JAVA多线程CountDownLatch的使用和原理。 什么时候用CountDownLatch? 在多线程编程中,我们经常会遇到这样一种情况:某个线程需要等待其他线程执行完毕后再继续执行。例如,在上面的代码中,...
本文将详细介绍CountDownLatch和CyclicBarrier的工作原理、使用场景以及如何在实际项目中应用它们。 CountDownLatch和CyclicBarrier是Java并发编程中两个非常有用的同步工具,它们在不同的场景下有着各自的优势。...
3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 4.1 场景介绍 4.2 使用CountDownLatch实现等待 CountDownLatch的其他应用场景 5.1 倒计时计时器 5.2 同时开始任务 5.3 等待多个资源就绪 CountDownLatch与...
本文将详细介绍 Java 并发工具类的四大类:CountDownLatch、Semaphore、CyclicBarrier 和 Phaser,及其应用场景和使用方法。 CountDownLatch CountDownLatch 是一个同步的辅助类,允许一个或多个线程,等待其他一...
SpringBoot ...使用 CountDownLatch 可以实现多任务并行处理,提高系统性能和用户体验。在我们的示例中,我们使用五个任务来模拟统计功能点的计算,但是使用 CountDownLatch 可以轻松地扩展到更多的任务。
在上述的代码示例中,`CountDownLatchExample2`展示了如何使用CountDownLatch和Semaphore结合,来控制并发线程的数目并确保所有线程执行完毕。`countDown()`方法在finally块中调用,以确保无论是否发生异常,计数器...
Java 利用 CountDownLatch 实现并行计算 ...本文介绍了 CountDownLatch 的使用和示例代码,演示了如何使用 CountDownLatch 实现并行计算。hope 本文能够帮助读者更好地理解并行计算和 CountDownLatch 的使用。
本文将详细介绍这三个辅助类的用法和实例详解。 一、CountDownLatch用法 CountDownLatch类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。它可以让一个线程等待其他线程执行完毕后再执行。...
本文将详细介绍 CountDownLatch 的用法实例,通过示例代码来讲解其使用方法。 CountDownLatch 的主要方法 CountDownLatch 有两个主要方法:countDown() 和 await()。 1. countDown() 方法: public void ...
JAVA 中的线程同步机制是非常重要的,CountDownLatch 和 thread-join() 是两种常用的线程同步方法,本文将详细介绍它们之间的区别。 首先, thread-join() 方法是Java语言中提供的一种线程同步机制,当一个线程调用...
本篇文章主要介绍了Java中的CountDownLatch类,作为Java并发编程专题(八)的一部分,通过实例讲解帮助读者理解和学习。下面是文章中的知识点总结: 一、CountDownLatch简介 CountDownLatch是一个同步辅助类,允许...
- CountDownLatch和CyclicBarrier:协调多个线程间的同步。 这些实例涵盖了Java开发中的诸多重要知识点,每个例子都提供了完整代码,方便读者实践和学习。通过这些实践,你可以加深对Java编程的理解,提升解决实际...
#### 一、CountDownLatch 基础介绍 `CountDownLatch` 可以被视为一种同步辅助工具,它的主要功能是允许一个或多个线程等待其他线程完成某些操作。具体来说,`CountDownLatch` 维护了一个内部计数器(初始值由用户...
本文将介绍让线程按顺序执行的8种方法,涉及到多线程中许多常用的方法,不止为了知道如何让线程按顺序运行,更是让读者对多线程的使用有更深刻的了解。 一、使用线程的join方法 join()是Thread的方法,作用是调用...
Java进阶教程,面试大全1,可参考以下问题: Semaphore-信号灯机制。 synchronized在静态方法和普通方法的区别。 怎么实现所有线程在等待某个事件的发生...CountDownLatch和CyclicBarrier的用法,以及相互之间的差别。
Java进阶教程,面试大全1,可参考以下问题: Semaphore-信号灯机制。 synchronized在静态方法和普通方法的区别。 怎么实现所有线程在等待某个事件的发生...CountDownLatch和CyclicBarrier的用法,以及相互之间的差别。