CountDownLatch是什么怎么用
时间: 2023-12-23 21:26:23 浏览: 78
Java并发包之CountDownLatch用法.docx
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("所有线程已完成任务");
}
}
```
阅读全文