Java 并发工具 CountDownLatch 技术详解

北漂老男孩

773人浏览 · 2025-09-12 00:15:00

北漂老男孩 · 2025-09-12 00:15:00 发布

Java 并发工具 CountDownLatch 技术详解

一、引言

在现代高并发的业务场景中，如何高效、优雅地完成多线程协作成为架构师和开发者关注的重点。CountDownLatch 是 Java java.util.concurrent 包下的一个常用并发工具类，常用于控制线程等待，协调多个线程并发执行与主流程的同步。本文将围绕 CountDownLatch 的设计思想、典型用法、源码解析、业务场景、调优技巧、与其他技术栈集成等进行系统性分析。

二、CountDownLatch 设计思想与应用流程

1. 设计思想

CountDownLatch 本质上是一个倒计数器，主线程（或任意线程）调用 await() 方法后会阻塞，直到计数器归零；而每个工作线程任务完成后调用 countDown()，使计数器减一，最终由主线程统一收尾。这种设计实现了一等多的线程同步，避免了繁琐的 join 操作。

技巧归纳

不可重置：CountDownLatch 计数器归零后不可复用，若需循环屏障应选用 CyclicBarrier。
原子性保证：内部使用 AQS (AbstractQueuedSynchronizer) 保证线程安全。
适合一次性事件：如任务分批、主流程等待子流程等。

2. 主流程流程图

flowchart TD
    A[主线程创建CountDownLatch] --> B{启动N个子线程}
    B --> C1[子线程1执行任务]
    B --> C2[子线程2执行任务]
    B --> Cn[子线程N执行任务]
    C1 --> D1[调用countDown()]
    C2 --> D2[调用countDown()]
    Cn --> Dn[调用countDown()]
    D1 & D2 & Dn --> E[主线程await阻塞]
    E --> F[计数归零，主线程继续]

三、核心源码与注释

1. 主要构造与方法

// 构造方法，初始化计数器
public CountDownLatch(int count);

// 主线程调用，阻塞直到计数归零
public void await() throws InterruptedException;

// 带超时等待
public boolean await(long timeout, TimeUnit unit) throws InterruptedException;

// 子线程调用，计数器-1
public void countDown();

2. 典型代码示例（逐行注释）

import java.util.concurrent.CountDownLatch;

public class Demo {
    public static void main(String[] args) throws InterruptedException {
        // 1. 创建计数器，计数2
        CountDownLatch latch = new CountDownLatch(2);

        // 2. 启动第一个子线程
        new Thread(() -> {
            System.out.println("子线程1开始执行...");
            try { Thread.sleep(1000); } catch (InterruptedException e) {}
            System.out.println("子线程1执行完毕");
            latch.countDown(); // 3. 计数器减1
        }).start();

        // 4. 启动第二个子线程
        new Thread(() -> {
            System.out.println("子线程2开始执行...");
            try { Thread.sleep(1500); } catch (InterruptedException e) {}
            System.out.println("子线程2执行完毕");
            latch.countDown(); // 5. 计数器再减1
        }).start();

        System.out.println("主线程等待2个子线程完成...");
        latch.await(); // 6. 阻塞，直到计数器为0
        System.out.println("所有子线程已完成，主线程继续执行");
    }
}

速记口诀

创建计数器，子线程减，主线程等，计数归零才通关。

四、实际业务场景剖析

1. 电商详情页并发加载

背景：详情页需汇总库存、价格、评价、推荐等多数据，分别由不同微服务提供，彼此无依赖。
实现：主线程 await，四个子线程并发获取模块数据，全部完成后汇总返回。
好处：充分利用多核、提升响应速度、代码简洁。

CountDownLatch latch = new CountDownLatch(4);
// 四个线程分别获取模块数据
// 每个线程结束后 latch.countDown()
// 主线程 latch.await()

2. 其他典型场景

并行压测任务，主线程等待所有子线程压测完成再统计。
多人游戏房间，全部玩家准备好后一起开始。
批量数据处理，所有子任务完成后统一汇总。

五、调试与优化技巧

避免死锁：确保所有分支都能执行 countDown()，否则主线程将永久阻塞。
超时处理：使用带超时的 await(long, TimeUnit)，防止子线程异常导致主线程无限等待。
线程池结合：建议配合 ExecutorService 提交任务，避免线程资源浪费。
可视化监控：通过日志打印 latch 剩余计数，便于定位问题。

六、与其他技术栈的集成与高阶应用

1. 与 Spring 集成

常见于异步接口聚合，结合 @Async 或线程池，提升接口并发能力。

2. 与分布式场景结合

分布式系统可用 RedissonCountDownLatch 实现跨节点同步（Redis 作为底层存储）。

3. 高阶应用

可用于服务降级：await 超时后自动降级返回。
与 CompletableFuture 结合，构建响应式并发流程。

七、底层实现与架构演进分析

1. 底层原理

基于 AQS（AbstractQueuedSynchronizer）实现。
countDown() 是原子操作，CAS 保证线程安全。
await() 方法通过 AQS 队列阻塞线程，直到计数归零唤醒。

2. 与 CyclicBarrier、Semaphore 对比

工具	适用场景	是否可重用	功能特点
CountDownLatch	一等多同步（一次性）	否	主线程等子线程
CyclicBarrier	多等多同步（可重用）	是	所有线程互等
Semaphore	控制并发数	是	资源限流、信号量控制