Java 中 CountDownLatch 在实现并发程序执行流程控制-Java面试题-PHP中文网

countdownlatch 是 java 并发包中用于线程同步的一次性工具，通过维护可递减的计数器实现“等待一组操作完成”；初始化后调用 countdown() 减计数，await() 阻塞直至计数归零，不可重置。

java 中 countdownlatch 在实现并发程序执行流程控制

CountDownLatch 是 Java 并发包中用于协调多个线程执行顺序的核心工具，它不控制线程的并发数量，而是让一个或多个线程等待其他线程完成指定任务后再继续执行。

CountDownLatch 的核心机制

CountDownLatch 内部维护一个计数器（int 类型），初始化时指定初始值。调用 countDown() 方法会使计数器减 1；调用 await() 的线程会阻塞，直到计数器变为 0 或被中断。一旦计数器归零，所有因 await() 阻塞的线程将被唤醒，且后续再调用 await() 将立即返回——CountDownLatch 是一次性使用的，不可重置。

典型使用场景

适用于“等待一组操作全部完成”这类同步需求：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

主线程启动多个子任务（如批量请求、数据预加载），需等全部完成后再汇总结果
测试中模拟多线程并发启动（如“同时开始”压测）
服务初始化阶段，等待多个依赖模块就绪后才对外提供服务

基本用法示例

以下代码演示主线程等待 3 个子线程完成工作：

CountDownLatch latch = new CountDownLatch(3);

for (int i = 0; i  {
        // 模拟耗时操作
        try { Thread.sleep(1000); } catch (InterruptedException e) {}
        System.out.println(Thread.currentThread().getName() + " 完成");
        latch.countDown(); // 计数器减1
    }).start();
}

try {
    latch.await(); // 主线程阻塞，直到计数器为0
    System.out.println("所有子任务已完成，继续执行...");
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}