当前位置：首页 > news >正文

CountDownLatch入门代码解析

news 来源：原创 2025/6/15 13:04:40

文章目录

- - 核心思想：火箭发射倒计时 🚀
  - 最简单易懂的代码示例
  - 代码解析
  - 运行流程分析

核心思想：火箭发射倒计时 🚀

想象一下发射火箭的场景，在按下最终的发射按钮之前，必须有好几个系统同时完成自检，比如：

燃料系统检查
引擎系统检查
导航系统检查

控制中心（主线程）必须等待这3个检查全部报告“正常”后，才能下达“发射”指令。

CountDownLatch 就好比是这个场景中的倒计时计数器。

CountDownLatch latch = new CountDownLatch(3);
- 这等于在控制中心设置了一个初始值为 3 的倒计时器。意味着我们需要等待3个检查任务完成。
latch.await(); (等待)
- 控制中心（主线程）调用这个方法，然后就进入等待状态。它会一直在这里被阻塞，直到倒计时器的数字变成 0。
latch.countDown(); (倒数)
- 每个检查系统（工作线程）在完成自己的任务后，就调用一次这个方法。
- 每调用一次，倒计时器的数字就减一。
- 当第三个检查系统也调用了 countDown() 后，倒计时器数字变为0，await() 的等待结束，控制中心（主线程）被唤醒，继续执行后续的发射指令。

最简单易懂的代码示例

下面我们就用代码来模拟这个“火箭发射”的场景。

package CoountDownLatch;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class SimpleCountDownLatchDemo {public static void main(String[] args) throws InterruptedException {// 1. 创建一个 CountDownLatch，计数器设置为 3//    意味着我们需要等待3个任务完成final CountDownLatch latch = new CountDownLatch(3);// 创建一个线程池来管理我们的检查任务ExecutorService executor = Executors.newFixedThreadPool(3);System.out.println("主控室：准备发射火箭，等待各系统检查...");// 2. 分配3个检查任务给不同的线程for (int i = 1; i <= 3; i++) {final String checkerName = "检查员-" + i;executor.submit(() -> {try {System.out.println("--> [" + checkerName + "] 开始进行系统检查...");// 模拟检查耗时Thread.sleep(new Random().nextInt(2000) + 1000); // 随机耗时1-3秒System.out.println("... [" + checkerName + "] 检查完成，已报告！");} catch (InterruptedException e) {e.printStackTrace();} finally {// 3. 关键！任务完成，调用 countDown()，计数器减一latch.countDown();}});}// 4. 主线程调用 await() 进入等待//    它会一直阻塞在这里，直到 latch 的计数器变为 0System.out.println("主控室：所有检查任务已派出，等待报告...");latch.await();// --- 当所有检查任务都调用了 countDown() 后，主线程才会从 await() 返回，执行以下代码 ---System.out.println("主控室：所有系统检查完成！准备发射！");System.out.println("3... 2... 1... 火箭发射！🚀");// 关闭线程池executor.shutdown();}
}