1. CountDownLatch核心原理与使用场景CountDownLatch是Java并发包(java.util.concurrent)中一个非常实用的同步辅助类它允许一个或多个线程等待其他线程完成操作后再继续执行。这个机制在需要协调多个线程执行顺序的场景中特别有用。1.1 核心工作机制CountDownLatch的实现基于一个计数器这个计数器在构造时初始化public CountDownLatch(int count) { if (count 0) throw new IllegalArgumentException(count 0); this.sync new Sync(count); }计数器的工作机制可以类比为运动会比赛比赛开始前裁判(主线程)等待所有运动员(工作线程)就位每个运动员到达起跑线就调用countDown()表示准备就绪当计数器归零时裁判发出起跑信号所有运动员开始比赛这个计数器有几个重要特性计数器的值只能递减不能重置当计数器值为零时所有等待的线程都会被释放如果计数器已经为零调用await()会立即返回1.2 主要API解析CountDownLatch的核心方法只有三个await()方法public void await() throws InterruptedException { sync.acquireSharedInterruptibly(1); }这个方法会使当前线程等待直到计数器减到零或者线程被中断。如果计数器已经为零调用会立即返回。await(long timeout, TimeUnit unit)public boolean await(long timeout, TimeUnit unit) throws InterruptedException { return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); }带超时的等待版本如果在指定时间内计数器没有减到零会返回false。countDown()方法public void countDown() { sync.releaseShared(1); }将计数器减1如果减到零则释放所有等待的线程。1.3 典型使用场景CountDownLatch特别适合以下几种场景并行任务同步主线程需要等待多个子线程完成初始化工作后再继续执行服务启动依赖某个服务需要等待其他服务启动完成后才能启动测试并发模拟高并发场景让多个线程同时开始执行数据分片处理等待所有数据分片处理完成后再进行汇总提示CountDownLatch的计数器是一次性的减到零后就不能再使用。如果需要可重用的版本可以考虑CyclicBarrier。2. CountDownLatch深度使用与实战技巧2.1 基础使用示例让我们看一个完整的示例模拟主线程等待多个子线程完成任务public class CountDownLatchDemo { public static void main(String[] args) throws InterruptedException { final int THREAD_COUNT 5; CountDownLatch startSignal new CountDownLatch(1); CountDownLatch doneSignal new CountDownLatch(THREAD_COUNT); for (int i 0; i THREAD_COUNT; i) { new Thread(new Worker(startSignal, doneSignal, i)).start(); } System.out.println(主线程准备启动所有工作线程...); startSignal.countDown(); // 释放所有工作线程 System.out.println(主线程等待所有工作线程完成...); doneSignal.await(); // 等待所有工作线程完成 System.out.println(所有工作线程已完成主线程继续执行); } static class Worker implements Runnable { private final CountDownLatch startSignal; private final CountDownLatch doneSignal; private final int workerId; Worker(CountDownLatch startSignal, CountDownLatch doneSignal, int workerId) { this.startSignal startSignal; this.doneSignal doneSignal; this.workerId workerId; } public void run() { try { System.out.println(工作线程 workerId 等待启动...); startSignal.await(); // 等待主线程信号 System.out.println(工作线程 workerId 开始工作...); Thread.sleep(1000 (int)(Math.random() * 2000)); // 模拟工作 System.out.println(工作线程 workerId 完成工作); doneSignal.countDown(); // 通知主线程完成 } catch (InterruptedException ex) { Thread.currentThread().interrupt(); } } } }这个示例展示了CountDownLatch的两种典型用法使用startSignal让所有工作线程同时开始使用doneSignal让主线程等待所有工作线程完成2.2 高级应用技巧多阶段任务控制CountDownLatch phase1 new CountDownLatch(5); CountDownLatch phase2 new CountDownLatch(5); // 第一阶段任务 for (int i 0; i 5; i) { new Thread(() - { // 执行第一阶段工作 phase1.countDown(); }).start(); } // 等待第一阶段完成 phase1.await(); // 第二阶段任务 for (int i 0; i 5; i) { new Thread(() - { // 执行第二阶段工作 phase2.countDown(); }).start(); } // 等待第二阶段完成 phase2.await();与线程池配合使用ExecutorService executor Executors.newFixedThreadPool(5); CountDownLatch latch new CountDownLatch(10); for (int i 0; i 10; i) { executor.execute(() - { try { // 执行任务 } finally { latch.countDown(); } }); } latch.await(); executor.shutdown();2.3 性能优化与注意事项避免过度使用CountDownLatch适用于一次性同步点频繁创建会影响性能合理设置计数器大小过大的计数器会浪费内存过小会导致线程阻塞确保countDown()被调用使用try-finally保证countDown()一定会执行处理中断await()方法会响应中断需要合理处理InterruptedException监控等待时间使用带超时的await()方法避免无限期等待重要提示CountDownLatch的计数器不能被重置如果需要重复使用同步屏障应该使用CyclicBarrier。3. CountDownLatch与其他并发工具对比3.1 与CyclicBarrier的区别虽然CountDownLatch和CyclicBarrier都用于线程协调但它们有几个关键区别特性CountDownLatchCyclicBarrier重用性不可重用可重用计数方向只能递减可重置等待机制工作线程不等待所有线程互相等待典型场景主线程等待工作线程线程组互相等待异常处理简单复杂(BrokenBarrierException)3.2 与Semaphore的区别Semaphore用于控制资源访问数量与CountDownLatch有本质区别特性CountDownLatchSemaphore目的线程协调资源控制计数递减到零触发可增减释放一次性可重复典型场景任务完成通知限流控制3.3 与Future/CompletableFuture的结合使用在Java 8中可以结合使用CountDownLatch和CompletableFutureCountDownLatch latch new CountDownLatch(3); CompletableFutureVoid future1 CompletableFuture.runAsync(() - { // 任务1 latch.countDown(); }); CompletableFutureVoid future2 CompletableFuture.runAsync(() - { // 任务2 latch.countDown(); }); CompletableFutureVoid future3 CompletableFuture.runAsync(() - { // 任务3 latch.countDown(); }); latch.await(); // 所有任务完成后的处理这种组合方式比单纯使用CountDownLatch更加灵活可以方便地添加回调处理。4. 常见问题与解决方案4.1 典型问题排查线程永久阻塞原因countDown()调用次数不足解决方案确保所有路径都会调用countDown()使用try-finally块计数器过早归零原因countDown()被多调用解决方案仔细检查计数逻辑确保与线程数匹配性能问题原因过多线程等待同一个latch解决方案考虑分片处理使用多个latch4.2 最佳实践总结资源释放try { // 执行任务 } finally { latch.countDown(); }超时处理if (!latch.await(10, TimeUnit.SECONDS)) { // 处理超时逻辑 }调试技巧打印计数器值System.out.println(当前计数 latch.getCount());使用有界队列线程池避免线程创建失败4.3 真实案例分享电商系统库存扣减场景public class InventoryService { private final ExecutorService executor Executors.newFixedThreadPool(10); public boolean reduceInventory(ListLong skuIds, ListInteger quantities) { CountDownLatch latch new CountDownLatch(skuIds.size()); AtomicBoolean success new AtomicBoolean(true); for (int i 0; i skuIds.size(); i) { final int index i; executor.execute(() - { try { if (!doReduce(skuIds.get(index), quantities.get(index))) { success.set(false); } } finally { latch.countDown(); } }); } try { latch.await(); return success.get(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); return false; } } private boolean doReduce(Long skuId, Integer quantity) { // 实际扣减库存逻辑 return true; } }这个案例展示了如何使用CountDownLatch来并行执行多个库存扣减操作并汇总所有操作结果。在实际项目中CountDownLatch的正确使用可以显著提高系统性能特别是在需要等待多个并行任务完成的场景。掌握它的原理和使用技巧是Java并发编程的重要一环。
1. CountDownLatch核心原理与使用场景CountDownLatch是Java并发包(java.util.concurrent)中一个非常实用的同步辅助类它允许一个或多个线程等待其他线程完成操作后再继续执行。这个机制在需要协调多个线程执行顺序的场景中特别有用。1.1 核心工作机制CountDownLatch的实现基于一个计数器这个计数器在构造时初始化public CountDownLatch(int count) { if (count 0) throw new IllegalArgumentException(count 0); this.sync new Sync(count); }计数器的工作机制可以类比为运动会比赛比赛开始前裁判(主线程)等待所有运动员(工作线程)就位每个运动员到达起跑线就调用countDown()表示准备就绪当计数器归零时裁判发出起跑信号所有运动员开始比赛这个计数器有几个重要特性计数器的值只能递减不能重置当计数器值为零时所有等待的线程都会被释放如果计数器已经为零调用await()会立即返回1.2 主要API解析CountDownLatch的核心方法只有三个await()方法public void await() throws InterruptedException { sync.acquireSharedInterruptibly(1); }这个方法会使当前线程等待直到计数器减到零或者线程被中断。如果计数器已经为零调用会立即返回。await(long timeout, TimeUnit unit)public boolean await(long timeout, TimeUnit unit) throws InterruptedException { return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); }带超时的等待版本如果在指定时间内计数器没有减到零会返回false。countDown()方法public void countDown() { sync.releaseShared(1); }将计数器减1如果减到零则释放所有等待的线程。1.3 典型使用场景CountDownLatch特别适合以下几种场景并行任务同步主线程需要等待多个子线程完成初始化工作后再继续执行服务启动依赖某个服务需要等待其他服务启动完成后才能启动测试并发模拟高并发场景让多个线程同时开始执行数据分片处理等待所有数据分片处理完成后再进行汇总提示CountDownLatch的计数器是一次性的减到零后就不能再使用。如果需要可重用的版本可以考虑CyclicBarrier。2. CountDownLatch深度使用与实战技巧2.1 基础使用示例让我们看一个完整的示例模拟主线程等待多个子线程完成任务public class CountDownLatchDemo { public static void main(String[] args) throws InterruptedException { final int THREAD_COUNT 5; CountDownLatch startSignal new CountDownLatch(1); CountDownLatch doneSignal new CountDownLatch(THREAD_COUNT); for (int i 0; i THREAD_COUNT; i) { new Thread(new Worker(startSignal, doneSignal, i)).start(); } System.out.println(主线程准备启动所有工作线程...); startSignal.countDown(); // 释放所有工作线程 System.out.println(主线程等待所有工作线程完成...); doneSignal.await(); // 等待所有工作线程完成 System.out.println(所有工作线程已完成主线程继续执行); } static class Worker implements Runnable { private final CountDownLatch startSignal; private final CountDownLatch doneSignal; private final int workerId; Worker(CountDownLatch startSignal, CountDownLatch doneSignal, int workerId) { this.startSignal startSignal; this.doneSignal doneSignal; this.workerId workerId; } public void run() { try { System.out.println(工作线程 workerId 等待启动...); startSignal.await(); // 等待主线程信号 System.out.println(工作线程 workerId 开始工作...); Thread.sleep(1000 (int)(Math.random() * 2000)); // 模拟工作 System.out.println(工作线程 workerId 完成工作); doneSignal.countDown(); // 通知主线程完成 } catch (InterruptedException ex) { Thread.currentThread().interrupt(); } } } }这个示例展示了CountDownLatch的两种典型用法使用startSignal让所有工作线程同时开始使用doneSignal让主线程等待所有工作线程完成2.2 高级应用技巧多阶段任务控制CountDownLatch phase1 new CountDownLatch(5); CountDownLatch phase2 new CountDownLatch(5); // 第一阶段任务 for (int i 0; i 5; i) { new Thread(() - { // 执行第一阶段工作 phase1.countDown(); }).start(); } // 等待第一阶段完成 phase1.await(); // 第二阶段任务 for (int i 0; i 5; i) { new Thread(() - { // 执行第二阶段工作 phase2.countDown(); }).start(); } // 等待第二阶段完成 phase2.await();与线程池配合使用ExecutorService executor Executors.newFixedThreadPool(5); CountDownLatch latch new CountDownLatch(10); for (int i 0; i 10; i) { executor.execute(() - { try { // 执行任务 } finally { latch.countDown(); } }); } latch.await(); executor.shutdown();2.3 性能优化与注意事项避免过度使用CountDownLatch适用于一次性同步点频繁创建会影响性能合理设置计数器大小过大的计数器会浪费内存过小会导致线程阻塞确保countDown()被调用使用try-finally保证countDown()一定会执行处理中断await()方法会响应中断需要合理处理InterruptedException监控等待时间使用带超时的await()方法避免无限期等待重要提示CountDownLatch的计数器不能被重置如果需要重复使用同步屏障应该使用CyclicBarrier。3. CountDownLatch与其他并发工具对比3.1 与CyclicBarrier的区别虽然CountDownLatch和CyclicBarrier都用于线程协调但它们有几个关键区别特性CountDownLatchCyclicBarrier重用性不可重用可重用计数方向只能递减可重置等待机制工作线程不等待所有线程互相等待典型场景主线程等待工作线程线程组互相等待异常处理简单复杂(BrokenBarrierException)3.2 与Semaphore的区别Semaphore用于控制资源访问数量与CountDownLatch有本质区别特性CountDownLatchSemaphore目的线程协调资源控制计数递减到零触发可增减释放一次性可重复典型场景任务完成通知限流控制3.3 与Future/CompletableFuture的结合使用在Java 8中可以结合使用CountDownLatch和CompletableFutureCountDownLatch latch new CountDownLatch(3); CompletableFutureVoid future1 CompletableFuture.runAsync(() - { // 任务1 latch.countDown(); }); CompletableFutureVoid future2 CompletableFuture.runAsync(() - { // 任务2 latch.countDown(); }); CompletableFutureVoid future3 CompletableFuture.runAsync(() - { // 任务3 latch.countDown(); }); latch.await(); // 所有任务完成后的处理这种组合方式比单纯使用CountDownLatch更加灵活可以方便地添加回调处理。4. 常见问题与解决方案4.1 典型问题排查线程永久阻塞原因countDown()调用次数不足解决方案确保所有路径都会调用countDown()使用try-finally块计数器过早归零原因countDown()被多调用解决方案仔细检查计数逻辑确保与线程数匹配性能问题原因过多线程等待同一个latch解决方案考虑分片处理使用多个latch4.2 最佳实践总结资源释放try { // 执行任务 } finally { latch.countDown(); }超时处理if (!latch.await(10, TimeUnit.SECONDS)) { // 处理超时逻辑 }调试技巧打印计数器值System.out.println(当前计数 latch.getCount());使用有界队列线程池避免线程创建失败4.3 真实案例分享电商系统库存扣减场景public class InventoryService { private final ExecutorService executor Executors.newFixedThreadPool(10); public boolean reduceInventory(ListLong skuIds, ListInteger quantities) { CountDownLatch latch new CountDownLatch(skuIds.size()); AtomicBoolean success new AtomicBoolean(true); for (int i 0; i skuIds.size(); i) { final int index i; executor.execute(() - { try { if (!doReduce(skuIds.get(index), quantities.get(index))) { success.set(false); } } finally { latch.countDown(); } }); } try { latch.await(); return success.get(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); return false; } } private boolean doReduce(Long skuId, Integer quantity) { // 实际扣减库存逻辑 return true; } }这个案例展示了如何使用CountDownLatch来并行执行多个库存扣减操作并汇总所有操作结果。在实际项目中CountDownLatch的正确使用可以显著提高系统性能特别是在需要等待多个并行任务完成的场景。掌握它的原理和使用技巧是Java并发编程的重要一环。
