CountDownLatch通过计数器实现线程同步,主线程调用await()等待,其他线程完成任务后调用countDown(),计数归零时释放主线程,常用于多线程初始化、并发测试等场景。

在Java多线程编程中,CountDownLatch 是一种非常实用的同步工具,它允许一个或多个线程等待其他线程完成操作后再继续执行。它的核心机制基于一个计数器,当计数器归零时,所有被阻塞的线程会被释放。
CountDownLatch的基本原理
CountDownLatch通过构造函数接收一个整型值,表示需要等待的事件数量。每当一个事件完成,调用 countDown() 方法将计数器减一。其他线程调用 await() 方法后会进入阻塞状态,直到计数器变为0。
典型应用场景包括:
主线程等待多个工作线程初始化完成多个线程并行处理任务,主线程汇总结果前需全部完成模拟并发请求测试系统性能
基本使用示例:主线程等待子线程完成
以下代码演示如何使用 CountDownLatch 让主线程等待三个工作线程执行完毕:
立即学习“Java免费学习笔记(深入)”;
import java.util.concurrent.CountDownLatch;public class WorkerExample {public static void main(String[] args) throws InterruptedException {int threadCount = 3;CountDownLatch latch = new CountDownLatch(threadCount);
for (int i = 1; i { System.out.println("任务 " + taskId + " 开始执行"); try { Thread.sleep(2000); // 模拟耗时操作 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println("任务 " + taskId + " 完成"); latch.countDown(); // 任务完成,计数减一 }).start(); } System.out.println("主线程等待所有任务完成..."); latch.await(); // 阻塞直到计数为0 System.out.println("所有任务已完成,主线程继续执行");}}
输出结果会显示主线程在所有子线程完成后才继续执行,体现了良好的同步控制。
稿定抠图
AI自动消除图片背景
76 查看详情
![]()
进阶应用:模拟高并发场景
CountDownLatch 也常用于压力测试中,确保多个线程在同一时刻发起请求:
import java.util.concurrent.CountDownLatch;public class ConcurrentTest {public static void main(String[] args) throws InterruptedException {int userCount = 100;CountDownLatch startSignal = new CountDownLatch(1);CountDownLatch doneSignal = new CountDownLatch(userCount);
for (int i = 0; i { try { startSignal.await(); // 所有线程在此等待 System.out.println(Thread.currentThread().getName() + " 发起请求"); // 模拟请求处理 Thread.sleep((long)(Math.random() * 1000)); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } finally { doneSignal.countDown(); } }).start(); } Thread.sleep(2000); // 准备时间 System.out.println("开始并发请求!"); startSignal.countDown(); // 释放所有等待线程 doneSignal.await(); // 主线程等待全部完成 System.out.println("所有请求已完成");}}
这种模式能有效模拟真实高并发环境,帮助评估系统性能。
注意事项与最佳实践
使用 CountDownLatch 时需注意以下几点:
计数器只能使用一次,一旦归零无法重置。如需重复使用,考虑 CyclicBarrier确保调用 countDown() 的次数与初始计数值一致,避免因遗漏导致死锁await() 可以被中断,应妥善处理 InterruptedException适用于“等待N个条件完成”的场景,不适合线程间频繁通信
基本上就这些。CountDownLatch 简洁高效,是实现线程协调的重要工具之一,掌握其使用对编写健壮的并发程序至关重要。
以上就是Java里如何使用CountDownLatch实现线程等待_CountDownLatch同步机制应用解析的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1066360.html
微信扫一扫
支付宝扫一扫