CyclicBarrier的 常用场景及使用示例

2024-05-15 23:12

本文主要是介绍CyclicBarrier的 常用场景及使用示例,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

CyclicBarrier的 常用场景及使用示例

CyclicBarrier是Java并发编程中的另一种同步辅助工具,它用于控制多个线程相互等待,直到所有线程都到达一个共同的屏障点,然后所有线程才会继续执行。与CountDownLatch不同的是,CyclicBarrier是可以重复使用的,即在所有线程释放后,屏障可以再次用于下一轮的同步。以下是CyclicBarrier的一些常用场景及一个简单的使用示例:

常用场景

  1. 并行计算后的汇总: 在并行处理大量数据后,需要等待所有处理线程完成,然后将结果汇总或进一步处理。
  2. 阶段任务同步: 在涉及多个步骤的处理流程中,每个阶段完成后,所有参与线程需要同步,确保下一阶段能从同一时间点开始。
  3. 游戏或模拟中的回合制同步: 在游戏或物理模拟中,可能需要所有参与者或模拟组件完成当前回合的操作后,再开始下一回合。
  4. 批量处理: 在分批次处理任务时,每个批次内的所有任务完成后再进行批次间的处理或切换。

使用示例

下面的示例演示了如何使用CyclicBarrier来同步四个工作线程,这些线程各自执行任务,然后等待所有线程完成后再一起进入下一轮工作:

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;public class CyclicBarrierExample {public static void main(String[] args) {int parties = 4; // 参与线程数CyclicBarrier barrier = new CyclicBarrier(parties, new Runnable() {@Overridepublic void run() {System.out.println("所有线程已到达屏障,开始汇总结果或进行下一轮准备...");}});for (int i = 0; i < parties; i++) {new Thread(new Worker(barrier, "Worker-" + i)).start();}}static class Worker implements Runnable {private final CyclicBarrier barrier;private final String name;Worker(CyclicBarrier barrier, String name) {this.barrier = barrier;this.name = name;}@Overridepublic void run() {try {for (int i = 0; i < 3; i++) { // 每个线程执行三次任务Thread.sleep((long) (Math.random() * 1000)); // 模拟任务执行时间System.out.println(name + " 第 " + (i + 1) + " 次任务完成");barrier.await(); // 等待所有线程完成当前轮次}} catch (InterruptedException | BrokenBarrierException e) {Thread.currentThread().interrupt();e.printStackTrace();}}}
}

在这个示例中,每个Worker线程执行三次任务,每次任务完成后调用barrier.await(),等待其他所有线程完成当前轮次的任务。当所有线程都调用了await(),屏障打开,所有线程继续执行下一轮,同时指定的Runnable(在这个例子中用于打印汇总信息)会被执行一次。CyclicBarrier的构造函数接受一个额外的Runnable参数,这个任务会在每个屏障点被所有线程跨越后执行,非常适合用来执行一些汇总或清理操作。

这篇关于CyclicBarrier的 常用场景及使用示例的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/993189

相关文章

HarmonyOS学习(七)——UI(五)常用布局总结

自适应布局 1.1、线性布局(LinearLayout) 通过线性容器Row和Column实现线性布局。Column容器内的子组件按照垂直方向排列,Row组件中的子组件按照水平方向排列。 属性说明space通过space参数设置主轴上子组件的间距,达到各子组件在排列上的等间距效果alignItems设置子组件在交叉轴上的对齐方式,且在各类尺寸屏幕上表现一致,其中交叉轴为垂直时,取值为Vert

JS常用组件收集

收集了一些平时遇到的前端比较优秀的组件,方便以后开发的时候查找!!! 函数工具: Lodash 页面固定: stickUp、jQuery.Pin 轮播: unslider、swiper 开关: switch 复选框: icheck 气泡: grumble 隐藏元素: Headroom

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

Hadoop企业开发案例调优场景

需求 (1)需求:从1G数据中,统计每个单词出现次数。服务器3台,每台配置4G内存,4核CPU,4线程。 (2)需求分析: 1G / 128m = 8个MapTask;1个ReduceTask;1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务(4    3    3) HDFS参数调优 (1)修改:hadoop-env.sh export HDFS_NAMENOD

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

Hadoop数据压缩使用介绍

一、压缩原则 (1)运算密集型的Job,少用压缩 (2)IO密集型的Job,多用压缩 二、压缩算法比较 三、压缩位置选择 四、压缩参数配置 1)为了支持多种压缩/解压缩算法,Hadoop引入了编码/解码器 2)要在Hadoop中启用压缩,可以配置如下参数

Makefile简明使用教程

文章目录 规则makefile文件的基本语法:加在命令前的特殊符号:.PHONY伪目标: Makefilev1 直观写法v2 加上中间过程v3 伪目标v4 变量 make 选项-f-n-C Make 是一种流行的构建工具,常用于将源代码转换成可执行文件或者其他形式的输出文件(如库文件、文档等)。Make 可以自动化地执行编译、链接等一系列操作。 规则 makefile文件

使用opencv优化图片(画面变清晰)

文章目录 需求影响照片清晰度的因素 实现降噪测试代码 锐化空间锐化Unsharp Masking频率域锐化对比测试 对比度增强常用算法对比测试 需求 对图像进行优化,使其看起来更清晰,同时保持尺寸不变,通常涉及到图像处理技术如锐化、降噪、对比度增强等 影响照片清晰度的因素 影响照片清晰度的因素有很多,主要可以从以下几个方面来分析 1. 拍摄设备 相机传感器:相机传

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

常用的jdk下载地址

jdk下载地址 安装方式可以看之前的博客: mac安装jdk oracle 版本:https://www.oracle.com/java/technologies/downloads/ Eclipse Temurin版本:https://adoptium.net/zh-CN/temurin/releases/ 阿里版本: github:https://github.com/