0

0

如何使用CyclicBarrier循环屏障_实现多线程分阶段同步执行

P粉602998670

P粉602998670

发布时间:2026-02-17 14:28:48

|

115人浏览过

|

来源于php中文网

原创

cyclicbarrier不能替代countdownlatch因其语义不同:前者是“全部到达后一起继续”且可重用,后者是“倒计数为零后释放等待线程”且不可重用;误用会导致串行、卡死或brokenbarrierexception。

如何使用cyclicbarrier循环屏障_实现多线程分阶段同步执行

为什么 CyclicBarrier 不能直接替代 CountDownLatch

因为语义完全不同:CyclicBarrier 是“等所有线程都到达某个点再一起往下走”,而 CountDownLatch 是“等倒数到零后,其他线程才能继续”。如果你在分阶段任务里误用 CountDownLatch,会发现阶段之间串行、无法复用、甚至卡死——它天生不支持“多轮同步”。

典型错误现象:BrokenBarrierException 频繁抛出,或某一轮之后所有线程永远阻塞在 await()。这往往是因为某个线程在上一轮异常退出,没重置屏障,或者你误把它当一次性开关用了。

  • CyclicBarrier 构造时指定的是“参与线程数”,不是“要等几次”
  • 每次所有线程调用 await() 后,屏障自动重置,下一轮可立即复用
  • 如果某线程被中断或超时,整个屏障会被打破,后续 await() 全部抛 BrokenBarrierException

怎么用 CyclicBarrier 实现三阶段同步执行

比如:10 个线程先并发执行预处理(阶段一),全部完成才一起进计算(阶段二),算完再统一写结果(阶段三)。关键不是“等完就结束”,而是“每阶段末尾集体卡一下”。

实操建议:

  • 初始化时传入线程总数:new CyclicBarrier(10),别写成 10 - 1 或动态算
  • 每个线程在阶段交接处调用 barrier.await(),不要漏掉任何一阶段的等待点
  • 避免在 await() 前做耗时操作(如 IO、锁竞争),否则会拖慢整组线程进入屏障的时间
  • 可选传入 Runnable 作为“屏障动作”,比如记录阶段开始时间:new CyclicBarrier(10, () -> log.info("Stage 2 start"))

示例片段(简化):

NoCode
NoCode

美团推出的零代码应用生成平台

下载
for (int i = 0; i < 10; i++) {
    new Thread(() -> {
        stage1(); // 预处理
        barrier.await(); // 等全部完成
        stage2(); // 计算
        barrier.await(); // 再等全部完成
        stage3(); // 写结果
    }).start();
}

CyclicBarrier.await() 的超时和异常怎么处理

不加超时的 await() 一旦有线程挂掉或卡住,其余线程就永久阻塞。生产环境必须设超时,且必须处理两种异常:TimeoutExceptionBrokenBarrierException

常见错误现象:只 catch InterruptedException,结果 TimeoutException 没捕获导致线程直接退出,屏障被破坏,其他线程全抛 BrokenBarrierException

  • 用带超时的 await(long timeout, TimeUnit unit),例如 barrier.await(5, TimeUnit.SECONDS)
  • 必须显式检查返回值或异常:超时后当前线程应主动清理资源并退出,避免污染后续阶段
  • BrokenBarrierException 表明屏障已失效,此时不要再调用 await(),也不该尝试 reset()——除非你确定所有线程都已脱离屏障逻辑

多个 CyclicBarrier 嵌套或混用时容易踩什么坑

没有“嵌套屏障”的概念。如果你在一个线程里先后 await 两个不同 CyclicBarrier 实例,它们完全独立;但若多个线程交叉 await 不同屏障,极易因线程调度顺序引发死锁或阶段错乱。

典型场景:主线程等子线程注册完再启动,子线程又等主线程发号施令——这时用一个 CyclicBarrier 就够了,别拆成两个。

  • 一个任务流只用一个 CyclicBarrier 实例,按阶段调用多次 await()
  • 不要在 await() 的回调 Runnable 里再触发另一个屏障的 await()
  • 注意线程池复用场景:如果线程池里的线程反复执行含 CyclicBarrier 的任务,确保每次任务都完整走完所有 await(),否则残留状态会影响下一次执行

最常被忽略的一点:屏障对象本身不是线程安全的“状态容器”,它的状态(是否 broken、当前计数)由内部锁保护,但如果你在回调里修改共享变量,仍需额外同步。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

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

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

675

2023.08.10

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

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

366

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

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

25

2026.01.21

C++多线程相关合集
C++多线程相关合集

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

24

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

98

2026.02.06

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

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

366

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

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

25

2026.01.21

C++多线程相关合集
C++多线程相关合集

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

24

2026.01.21

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

283

2026.02.13

热门下载

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

精品课程

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

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