CountDownLatch是什么
时间: 2023-10-24 22:33:59 浏览: 97
CountDownLatch是一个在多线程并发环境中使用的工具类。它可以初始化一个全局计数器,并通过调用countDown()方法减少计数器的值,直到计数器的值减少到0时,通过await()挂起的线程将被唤醒。这个机制可以实现一个线程等待一组线程执行完、实现一个线程释放一组线程、多个线程释放多个线程的场景。<span class="em">1</span><span class="em">2</span><span class="em">3</span><span class="em">4</span>
相关问题
CountDownLatch是什么怎么用
CountDownLatch是Java中的一个同步工具类,它可以让一个线程等待其他线程完成它们的工作后再执行。CountDownLatch通过一个计数器来实现,计数器的初始值可以设置为任意值,当一个线程完成了自己的任务后,计数器的值就会减1,当计数器的值为0时,表示所有的线程都已经完成了任务,等待的线程就可以继续执行了。
使用CountDownLatch需要注意以下两点:
1. 一旦计数达到零,就不能重用CountDownLatch,这是CountDownLatch和CyclicBarrier之间的主要区别。
2. 主线程通过调用CountDownLatch.await()方法来等待latch线程完成,而其他线程则调用CountDownLatch.countDown()来通知它们已完成。
下面是一个使用CountDownLatch的例子,其中有5个线程,它们会分别睡眠1~5秒钟,然后通知主线程它们已完成任务,主线程等待所有线程完成后输出"所有线程已完成任务"。
```java
import java.util.concurrent.CountDownLatch;
public class CountDownLatchDemo {
public static void main(String[] args) throws InterruptedException {
int count = 5;
CountDownLatch latch = new CountDownLatch(count);
for (int i = 1; i <= count; i++) {
new Thread(() -> {
try {
Thread.sleep(i * 1000);
System.out.println(Thread.currentThread().getName() + " 完成任务");
latch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}, "线程" + i).start();
}
latch.await();
System.out.println("所有线程已完成任务");
}
}
```
CountDownLatch是什么其使用场景
CountDownLatch是Java中的一个同步辅助类,它可以用于控制多个线程之间的同步。
CountDownLatch的使用场景是在一个或多个线程等待其他线程完成某些操作后再继续执行。它通常用于以下情况:
1. 主线程等待多个子线程完成任务后再进行进一步操作。
2. 多个子线程等待某个主线程发出信号后再同时开始执行。
3. 多个子线程等待某个共享资源达到某个状态后再同时执行。
CountDownLatch通过一个计数器来实现,该计数器初始值为指定的数目(可以是任意正整数),每当一个线程完成一次计数操作,计数器的值就会减1。当计数器的值变为0时,所有在等待的线程都会被释放,可以继续执行。
使用CountDownLatch需要注意的是,计数器的值一旦减为0就不能再重置,如果需要重置计数器,可以使用CyclicBarrier类。
阅读全文