0

0

在Java中如何使用CountDownLatch_Java并发协作工具解析

P粉602998670

P粉602998670

发布时间:2026-01-13 11:01:25

|

991人浏览过

|

来源于php中文网

原创

countdownlatch 是一个一次性同步辅助类,用于让一个或多个线程等待其他线程完成指定数量的操作;适用于主线程等待多个子任务(如批量 http 请求)全部完成后再汇总结果的场景。

在java中如何使用countdownlatch_java并发协作工具解析

CountDownLatch 是什么,什么时候该用它

CountDownLatch 不是锁,而是一个同步辅助类,用来让一个或多个线程等待其他线程完成一组操作。典型场景是:主线程启动若干子任务(比如 5 个 HTTP 请求),等它们全部返回后再汇总结果——这时 CountDownLatch 比轮询或 join() 更可控、更轻量。

它内部维护一个计数器,初始化时指定值;每次调用 countDown() 就减 1;调用 await() 的线程会阻塞,直到计数器归零或被中断。

初始化和基本用法要注意哪些坑

最常见错误是把 CountDownLatch 初始化为 0:此时 await() 不会阻塞,直接返回,导致逻辑提前执行。另一个坑是重复调用 countDown() 超过初始值,虽然不会报错,但可能掩盖逻辑错误(比如本该只触发一次的清理动作被多执行)。

  • 计数值必须大于 0 才有意义,new CountDownLatch(0) 适合“立即放行”场景,但需明确意图
  • 每个参与协作的线程应且仅调用一次 countDown(),建议放在 finally 块里防异常跳过
  • await() 可带超时参数,避免无限等待;返回 false 表示超时,需主动处理失败路径

和 CyclicBarrier、Semaphore 的关键区别在哪

三者都用于线程协作,但语义不同:CyclicBarrier 是“大家一起到齐才出发”,可重用;Semaphore 控制并发数,类似限流器;而 CountDownLatch 是“等别人干完我再动”,一次性且不可重置。

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

下载

立即学习Java免费学习笔记(深入)”;

如果需要多次等待同一组事件(比如每轮批处理都等 10 个任务完成),别硬用 CountDownLatch —— 它不能 reset,得换 CyclicBarrier 或手动 new 新实例(不推荐,易泄漏)。

  • CountDownLatch:单次倒计时,不可重用
  • CyclicBarrier:可重复使用,支持到达时触发回调(Runnable
  • Semaphore:控制同时访问资源的线程数,和“等待完成”无直接关系

一个真实可用的 HTTP 批量请求示例

下面代码模拟 3 个异步请求并发执行,主线程等待全部完成。注意异常处理、超时控制和资源释放:

CountDownLatch latch = new CountDownLatch(3);
List<String> results = Collections.synchronizedList(new ArrayList<>());

for (int i = 0; i < 3; i++) {
    int taskId = i;
    new Thread(() -> {
        try {
            // 模拟网络请求
            String result = "response-" + taskId;
            Thread.sleep(1000L);
            results.add(result);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            latch.countDown(); // 确保一定执行
        }
    }).start();
}

try {
    if (!latch.await(5, TimeUnit.SECONDS)) {
        System.err.println("Timeout waiting for all tasks");
        return;
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    return;
}

System.out.println("All done: " + results);

实际项目中,更推荐用 CompletableFuture 替代手写 CountDownLatch,尤其在需要链式处理、异常传播或组合多个异步结果时。但理解 CountDownLatch 的底层协作模型,对排查并发问题仍有直接帮助。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

723

2023.08.10

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

723

2023.08.10

http500解决方法
http500解决方法

http500解决方法有检查服务器日志、检查代码错误、检查服务器配置、检查文件和目录权限、检查资源不足、更新软件版本、重启服务器或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

482

2023.11.09

http请求415错误怎么解决
http请求415错误怎么解决

解决方法:1、检查请求头中的Content-Type;2、检查请求体中的数据格式;3、使用适当的编码格式;4、使用适当的请求方法;5、检查服务器端的支持情况。更多http请求415错误怎么解决的相关内容,可以阅读下面的文章。

448

2023.11.14

HTTP 503错误解决方法
HTTP 503错误解决方法

HTTP 503错误表示服务器暂时无法处理请求。想了解更多http错误代码的相关内容,可以阅读本专题下面的文章。

3153

2024.03.12

http与https有哪些区别
http与https有哪些区别

http与https的区别:1、协议安全性;2、连接方式;3、证书管理;4、连接状态;5、端口号;6、资源消耗;7、兼容性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2746

2024.08.16

Golang 测试体系与代码质量保障:工程级可靠性建设
Golang 测试体系与代码质量保障:工程级可靠性建设

Go语言测试体系与代码质量保障聚焦于构建工程级可靠性系统。本专题深入解析Go的测试工具链(如go test)、单元测试、集成测试及端到端测试实践,结合代码覆盖率分析、静态代码扫描(如go vet)和动态分析工具,建立全链路质量监控机制。通过自动化测试框架、持续集成(CI)流水线配置及代码审查规范,实现测试用例管理、缺陷追踪与质量门禁控制,确保代码健壮性与可维护性,为高可靠性工程系统提供质量保障。

28

2026.02.28

Golang 工程化架构设计:可维护与可演进系统构建
Golang 工程化架构设计:可维护与可演进系统构建

Go语言工程化架构设计专注于构建高可维护性、可演进的企业级系统。本专题深入探讨Go项目的目录结构设计、模块划分、依赖管理等核心架构原则,涵盖微服务架构、领域驱动设计(DDD)在Go中的实践应用。通过实战案例解析接口抽象、错误处理、配置管理、日志监控等关键工程化技术,帮助开发者掌握构建稳定、可扩展Go应用的最佳实践方法。

23

2026.02.28

Golang 性能分析与运行时机制:构建高性能程序
Golang 性能分析与运行时机制:构建高性能程序

Go语言以其高效的并发模型和优异的性能表现广泛应用于高并发、高性能场景。其运行时机制包括 Goroutine 调度、内存管理、垃圾回收等方面,深入理解这些机制有助于编写更高效稳定的程序。本专题将系统讲解 Golang 的性能分析工具使用、常见性能瓶颈定位及优化策略,并结合实际案例剖析 Go 程序的运行时行为,帮助开发者掌握构建高性能应用的关键技能。

27

2026.02.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4万人学习

C# 教程
C# 教程

共94课时 | 10.5万人学习

Java 教程
Java 教程

共578课时 | 75万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号