CyclicBarrier是一种可重用的同步工具，允许多个线程在到达屏障点后集体继续执行。其核心是通过await()方法使线程相互等待，直至所有线程都调用了await()，再统一放行，并可执行预设的barrierAction任务。与CountDownLatch不同，CyclicBarrier支持循环使用，调用reset()即可重置状态。文中以分段求和为例，展示如何将大数组拆分给多个线程并行计算局部和，最后利用barrierAction汇总结果。关键点包括：使用共享数组存储各线程结果、确保线程写入位置不冲突、处理await可能抛出的异常、避免barrierAction耗时过长导致阻塞。适用于多阶段协同计算、并发测试、游戏同步等场景。注意一旦有线程中断可能导致屏障破裂，需合理管理线程生命周期。
在Java并发编程中，当需要将一个大任务拆分成多个子任务并行执行，并在所有子任务完成后再进行下一步操作时，CyclicBarrier 是一种非常实用的同步工具。它允许一组线程相互等待，直到所有线程都到达某个公共屏障点，然后再继续执行。这种机制特别适合用于分段计算、数据批量处理等场景。
什么是CyclicBarrier？
CyclicBarrier 字面意思是“循环栅栏”，它可以实现多个线程在执行到某一点时互相等待，直到所有线程都到达这个点后，才一起继续执行。与 CountDownLatch 不同的是，CyclicBarrier 可以被重用（即“循环”），只要调用 reset() 方法就可以重新初始化。
其构造函数有两种：
CyclicBarrier(int parties)：指定需要等待的线程数量。CyclicBarrier(int parties, Runnable barrierAction)：在所有线程到达屏障后，优先执行 barrierAction 指定的任务。
使用CyclicBarrier实现分段计算
假设我们要对一个大数组求和，可以将其拆分为多个片段，每个线程负责一段的计算，最后汇总结果。这时就可以借助 CyclicBarrier 等待所有线程完成各自的计算后再进行总和统计。
立即学习“Java免费学习笔记（深入）”；
示例代码如下：
稿定抠图
AI自动消除图片背景
76 查看详情
import java.util.concurrent.CyclicBarrier;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class SegmentCalculation {private static final int ARRAY_SIZE = 10000;private static final int THREAD_COUNT = 4;private static final int[] data = new int[ARRAY_SIZE];private static final long[] partialSums = new long[THREAD_COUNT]; // 存储每段的结果private static final CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> {// 所有线程完成后的聚合操作long total = 0;for (long sum : partialSums) {total += sum;}System.out.println("最终总和为：" + total);});
public static void main(String[] args) { // 初始化数据 for (int i = 0; i < ARRAY_SIZE; i++) { data[i] = 1; } ExecutorService executor = Executors.newFixedThreadPool(THREAD_COUNT); int segmentSize = ARRAY_SIZE / THREAD_COUNT; for (int i = 0; i { long sum = 0; for (int j = start; j < end; j++) { sum += data[j]; } partialSums[taskId] = sum; System.out.println("线程 " + taskId + " 计算完成，局部和：" + sum); try { barrier.await(); // 等待其他线程 } catch (Exception e) { e.printStackTrace(); } }); } executor.shutdown();}}
关键设计要点说明
共享结果数组：使用
partialSums数组保存每个线程的计算结果，注意下标与线程一一对应，避免冲突。屏障动作（barrierAction）：在构造 CyclicBarrier 时传入的 Runnable 会在所有线程调用 await() 后执行一次，适合做汇总或清理工作。异常处理：await() 方法可能抛出InterruptedException或BrokenBarrierException，需合理捕获。线程安全：虽然本例中各线程写入不同的 partialSums 元素，不存在竞争，但如果涉及共享变量，仍需考虑同步问题。适用场景与注意事项
CyclicBarrier 适用于多线程协同完成阶段性任务的场景，比如：
多阶段并行计算（如矩阵运算分块）模拟并发请求的压力测试游戏中的角色同步行动
需要注意：
一旦屏障被打破（例如某个线程中断），CyclicBarrier 会进入“broken”状态，后续 await 调用也会失败。可通过调用
reset()方法重置屏障，恢复正常使用，常用于循环任务。不要在 barrierAction 中执行耗时过长的操作，以免阻塞所有等待线程。基本上就这些。CyclicBarrier 提供了一种简洁有效的线程同步方式，结合任务拆分策略，能显著提升计算密集型任务的效率。实际使用中可根据数据规模动态调整线程数和分段策略，达到最佳性能平衡。
以上就是Java如何使用CyclicBarrier实现分段计算_Java任务拆分与同步方案的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1027955.html
微信扫一扫 
支付宝扫一扫 
