最近在看ZK的源码,看到了有用到java.util.concurrent.CountDownLatch 这个类。总结一下用法:
CountDownLatch,一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。 主要方法 public CountDownLatch(int count); public void countDown(); public void await() throws InterruptedException 构造方法参数指定了计数的次数 countDown方法,当前线程调用此方法,则计数减1 awaint方法,调用此方法会一直阻塞当前线程,直到计时器的值为0
下面通过一个例子展示,程序会一直等待countDownLatch的值变成0,才会打印出:“工人们做完了。”。
package com.get.set;
import java.util.concurrent.CountDownLatch;
public class CountDownLatchDemo{
public static void main(String args[]){
CountDownLatch countDownLatch=new CountDownLatch(2);
Worker workA=new Worker("wjy", countDownLatch);
Worker workB=new Worker("yuanyuan", countDownLatch);
workA.start();
workB.start();
try {
countDownLatch.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("工人们做完了。");
}
static class Worker extends Thread{
private String name;
private CountDownLatch countDownLatch;
public Worker(String name,CountDownLatch countDownLatch){
this.name=name;
this.countDownLatch=countDownLatch;
}
@Override
public void run(){
System.out.println("Hello, I am "+name);
this.countDownLatch.countDown();
}
}
}
//运行结果:
Hello, I am wjy
Hello, I am yuanyuan
工人们做完了。
注意:如果我们把CountDownLatch的初始值设为3,那么在上面这个程序中永远都不会打印出“工人们做完了。”
因为,程序会一直等待countDownLatch的值变成0.但是countDownLatch的值永远不可能变成0了。
相关推荐
5. **一次性使用**:CountDownLatch的设计是一次性的,即一旦计数器归零,就不能再次使用。如果尝试再次调用`await()`或`countDown()`,它将抛出`IllegalStateException`。 6. **并发性能**:由于CountDownLatch是...
4. **一次性使用**: 一旦计数器归0,`await()`将不再阻塞任何线程,且CountDownLatch不能重置,只能一次性使用。 **CyclicBarrier** CyclicBarrier则更像一个障碍,它允许一组线程彼此等待,直到所有的线程都到达...
本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始化时设定一个初始值,通常表示一个任务的子任务数量。每个线程完成其工作后会调用`countDown()`方法,...
`CountDownLatch`是Java并发包`java.util.concurrent`...如果一个任务可以被分解成多个独立部分,可以使用`CountDownLatch`并行执行这些部分,然后主线程等待所有部分完成后再进行汇总,这样可以显著提高整体执行效率。
递减锁存器CountDownLatch的使用以及注意事项!
在Java并发编程中,`CountDownLatch`是一个非常重要的工具类,它位于`java.util.concurrent`包下,用于协调多个线程间的同步。...理解和熟练使用`CountDownLatch`对于编写高效的多线程Java程序至关重要。
1. **初始化异步操作**:在 Activity 或 Fragment 的生命周期方法中,如果需要先执行一系列异步操作(如网络请求、数据库初始化等)再显示界面,可以使用 `CountDownLatch` 来等待这些异步操作完成。 2. **并发测试...
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴 java并发编程中CountDownLatch和CyclicBarrier是两个非常重要的线程控制和调度工具,经常被用于解决多线程程序设计中的线程等待问题。本文将对...
2. **如何避免死锁与饥饿**:在使用CountDownLatch时,要确保所有线程都能正确调用`countDown()`,避免因某个线程异常而无法达到零导致死锁。 3. **如何选择合适的同步工具**:根据场景选择,如果需要所有线程执行完...
CountDownLatch的使用方法: 1. 创建CountDownLatch对象:使用new关键字创建一个CountDownLatch对象,并指定线程的数量。 2. 等待线程执行完成:使用await()方法使得当前线程等待其他线程执行完成。 3. 唤醒阻塞...
JAVA多线程CountDownLatch使用详解 JAVA多线程CountDownLatch是JAVA多线程编程中的一种同步工具,主要用来让某个线程等待其他线程执行完毕后再继续执行。下面我们将详细介绍JAVA多线程CountDownLatch的使用和原理。...
在批量插入数据的场景下,可以创建一个CountDownLatch对象,初始化为线程的数量,每个线程处理完自己的数据后调用`countDown()`方法,主线程通过调用`await()`方法等待所有线程完成后再执行后续操作,如提交事务。...
文章目录1 原理简介2 具体使用方法2.1 demo1 — await不传入时间,保证当前线程的其他操作在最后执行2.2 demo2 — await传入时间t,当前线程等其他线程时间t后就运行其他操作2.3 发令枪 源码地址:...
主线程必须在启动其他线程后立即调用 CountDownLatch.await()方法,其他 N 个线程必须引用闭锁对象,因为他们需要通知 CountDownLatch 对象,他们已经完成了各自的任务。 在实际开发中,CountDownLatch 可以用来...
CountDownLatch与thread.join()的区别
在这个"CountDownLatch Demo"中,我们将深入理解 CountDownLatch 的原理、用法以及如何在实际项目中应用。 CountDownLatch 的核心概念在于一个计数器(count),初始化时设置为一个非负整数。这个计数器通过 `...
CountDownLatch 是 Java 中的一个同步工具类,位于 `java.util.concurrent` 包下,它主要用于多线程间的协作,...正确使用 CountDownLatch 可以提高程序的并发性能,避免不必要的等待,同时确保任务的正确顺序执行。
本文将深入探讨CountDownLatch的工作原理、使用方法以及它在并发编程中的应用场景。 1. **CountDownLatch简介** CountDownLatch是一个计数器,初始化时设置一个初始值,然后多个线程可以等待这个计数器归零。一旦...
CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 4.1 场景介绍 4.2 使用...
下面我们将深入探讨CountDownLatch的原理、使用方法以及与CyclicBarrier的区别。 首先,CountDownLatch的构造函数接受一个整数参数`count`,这个值表示计数器的初始值。当这个计数器归零时,所有等待在`await()`...