在Java里如何使用CountDownLatch实现线程等待_Java同步工具解析_技术教程

CountDownLatch 是一个同步辅助类，用于让一个或多个线程等待其他线程完成一组操作；其核心是基于计数器的 await() 阻塞与 countDown() 减一机制，适用于主线程等待子任务完成、服务初始化就绪等场景，且不可重置。

CountDownLatch 是什么，什么时候该用它

CountDownLatch 不是锁，而是一个同步辅助类，用来让一个或多个线程等待其他线程完成一组操作。它的核心是内部一个 count 计数器，调用 countDown() 会减一，调用 await() 的线程会阻塞直到计数器归零。

典型场景包括：主线程等待多个子任务全部完成再继续；测试中模拟并发启动；服务启动时等待所有初始化模块就绪。

注意：它是一次性用品——计数器归零后，await() 立即返回，不能再重置（想重复用请换 CyclicBarrier）。

基本用法：初始化、倒计时、等待三步走

构造时指定初始计数值，每个协作线程完成工作后调用 countDown()；主控线程在关键点调用 await() 阻塞等待。

CountDownLatch 构造参数必须 > 0，否则抛 IllegalArgumentException
await() 可被中断，需处理 InterruptedException
countDown() 是无锁的 CAS 操作，安全且轻量

CountDownLatch latch = new CountDownLatch(3);

// 启动 3 个子线程
for (int i = 0; i < 3; i++) {
    new Thread(() -> {
        try {
            // 模拟任务执行
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return;
        }
        System.out.println("Task done");
        latch.countDown(); // 计数器减一
    }).start();
}

try {
    latch.await(); // 主线程等待所有子线程完成
    System.out.println("All tasks finished");
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}