CountDownLatch通过计数器实现线程同步，初始化指定计数值，每调用一次countDown()计数减一，当计数为零时await()阻塞的线程被唤醒继续执行，适用于主线程等待多个子任务完成的场景，如数据加载、并发测试等，但计数器不可重置，需确保countDown()调用次数与初始值一致，否则可能导致死锁。
在Java并发编程中，CountDownLatch 是一个非常实用的同步工具类，它允许一个或多个线程等待其他线程完成操作后再继续执行。它的核心机制是基于一个计数器，当计数器归零时，所有被阻塞的线程将被唤醒并继续运行。
CountDownLatch的基本原理
CountDownLatch内部维护一个计数器，初始化时指定计数值（通常等于需要等待的子任务数量）。每当一个任务完成，调用 countDown() 方法使计数减一。其他线程通过调用 await() 方法阻塞自己，直到计数器变为0。
关键点：
计数器不能重置，一旦归零，后续调用 await() 不会再阻塞。适用于“等待N个任务完成”的场景，比如启动服务前等待配置加载、多线程计算汇总等。
实战：模拟并行任务的协同执行
假设我们要开发一个数据处理系统，主线程需要等待3个子线程分别从不同数据源加载数据完成后，再进行汇总分析。
立即学习“Java免费学习笔记（深入）”；
代码示例：
AppMall应用商店
AI应用商店，提供即时交付、按需付费的人工智能应用服务
56 查看详情
import java.util.concurrent.CountDownLatch;public class DataProcessor {public static void main(String[] args) {int taskCount = 3;CountDownLatch latch = new CountDownLatch(taskCount);
for (int i = 1; i { System.out.println("线程 " + taskId + " 开始加载数据..."); try { Thread.sleep((long)(Math.random() * 3000)); // 模拟耗时 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println("线程 " + taskId + " 数据加载完成！"); latch.countDown(); // 完成后计数减一 }).start(); } System.out.println("主线程等待所有数据加载完成..."); try { latch.await(); // 阻塞直到计数为0 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println("所有数据已就绪，开始汇总分析！");}}
输出可能如下：
线程 2 开始加载数据...
线程 1 开始加载数据...
线程 3 开始加载数据...
主线程等待所有数据加载完成...
线程 1 数据加载完成！
线程 3 数据加载完成！
线程 2 数据加载完成！
所有数据已就绪，开始汇总分析！应用场景与注意事项
CountDownLatch适合以下典型场景：
主线程等待多个工作线程启动完成：如测试中确保所有线程都已进入运行状态。分阶段任务协调：例如，多个前置任务完成后才能进入下一阶段。性能测试中的并发控制：让多个线程同时开始执行以模拟高并发。
使用时注意：
确保调用 countDown() 的次数与初始化值一致，避免因遗漏导致死锁。如果需要重复使用，应考虑使用 CyclicBarrier 而非 CountDownLatch。await() 可以带超时参数，防止无限等待：await(long timeout, TimeUnit unit)。
基本上就这些，合理使用CountDownLatch能让线程协作更清晰可控。
以上就是在Java中如何使用CountDownLatch进行线程等待_CountDownLatch实战应用的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/298327.html
微信扫一扫 
支付宝扫一扫 
