0

0

在Java中如何使用CyclicBarrier同步多个线程_Java线程同步工具解析

P粉602998670

P粉602998670

发布时间:2026-02-06 10:24:09

|

285人浏览过

|

来源于php中文网

原创

该用 CyclicBarrier 而不是 CountDownLatch 的场景是需要多线程分阶段协作且屏障可重用时,如多玩家回合同步、mini-batch 数据校验;因其可重置,而 CountDownLatch 仅适用于一次性初始化等待。

在java中如何使用cyclicbarrier同步多个线程_java线程同步工具解析

什么时候该用 CyclicBarrier 而不是 CountDownLatch

核心区别在于复用性:CyclicBarrier 可重置、可重复使用;CountDownLatch 一旦计数归零就不可逆。如果你的任务是「多线程分阶段协作」,比如每轮都需等所有线程到达某个检查点再一起继续(如并行计算的迭代步、模拟中的时间片同步),CyclicBarrier 更合适。

常见误用场景:用 CountDownLatch 做阶段性等待——结果只能用一次,第二轮就得新建实例,逻辑臃肿且易出竞态。

  • 适合 CyclicBarrier:多玩家回合制游戏每轮同步、分布式测试中多个客户端统一启停、机器学习 mini-batch 训练前的数据校验同步
  • 不适合:一次性初始化等待(如服务启动时加载配置),选 CountDownLatch 更轻量

CyclicBarrier 构造与基本用法要点

最常用构造函数是 new CyclicBarrier(int parties)parties 表示需要等待的线程总数。注意:这个数必须和实际调用 await() 的线程数严格一致,少一个则永远阻塞,多一个会抛 BrokenBarrierException

关键行为:每个线程调用 await() 后被挂起,直到第 parties 个线程调用,所有线程才同时唤醒继续执行。

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

  • await() 是可中断的,若线程在等待时被 interrupt(),抛 InterruptedException,屏障自动进入破损状态
  • 可选构造函数 new CyclicBarrier(int parties, Runnable barrierAction),由最后一个到达的线程执行该回调,常用于汇总结果或日志记录
  • 回调 barrierAction 若抛异常,会导致所有等待线程收到 BrokenBarrierException

如何安全处理 BrokenBarrierException 和屏障破损

BrokenBarrierException 不仅在屏障被中断时抛出,也出现在任一线程在 await() 中超时、异常退出、或 barrierAction 抛异常之后。此时屏障已损坏,后续所有 await() 都会立即抛该异常,除非手动重置。

爱AI工具库
爱AI工具库

爱AI工具库是一个实用的AI工具导航网站

下载

典型错误:只捕获 InterruptedException,忽略 BrokenBarrierException,导致后续线程陷入不可预期失败。

  • 必须显式捕获 BrokenBarrierException 并决定是否重试或退出
  • 调用 reset() 可恢复屏障,但会唤醒所有等待线程并令其收到 BrokenBarrierException —— 所以重置前应确保无线程仍在 await()
  • 生产环境建议配合 try-catch-finally:在 finally 块里检查 isBroken(),必要时记录告警

性能与线程安全注意事项

CyclicBarrier 内部基于 ReentrantLockCondition 实现,本身线程安全,但不解决业务逻辑的竞态。例如多个线程在 barrierAction 中写共享变量,仍需额外同步。

小规模线程(≤ 数十)下性能良好;但若 parties 过大(如上千),每次 await 都需原子更新计数+条件唤醒,开销上升,且容易因个别线程延迟拖慢整体进度。

  • 避免在 barrierAction 中做耗时操作(如 I/O、远程调用),否则会阻塞所有线程的下一步执行
  • 不要在 await() 前持有其他锁,否则可能引发死锁(如线程 A 持锁等屏障,线程 B 在屏障回调中试图获取同一锁)
  • 调试时留意线程 dump 中的 java.util.concurrent.CyclicBarrier$Generation 状态,破损屏障通常显示为 broken=true

真正难的不是调用 await(),而是设计好「谁该等、等什么、等完做什么」——屏障只是同步点,背后的数据依赖和生命周期管理,得靠你提前想清楚。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

377

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

238

2023.10.07

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

606

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

551

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

173

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

204

2025.08.29

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

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

612

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

281

2025.12.24

Golang处理数据库错误教程合集
Golang处理数据库错误教程合集

本专题整合了Golang数据库错误处理方法、技巧、管理策略相关内容,阅读专题下面的文章了解更多详细内容。

2

2026.02.06

热门下载

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

精品课程

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

共23课时 | 3.3万人学习

C# 教程
C# 教程

共94课时 | 8.7万人学习

Java 教程
Java 教程

共578课时 | 59万人学习

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

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