Java 详解循环屏障CyclicBarrier如何实现多线程分段等待执行完成
作者：剑客阿良_ALiang 发布时间：2022-02-16 04:50:49
前言
工作中是否有这样的场景，多个线程任务，如果所有线程完成到某个阶段，你希望知道所有线程均完成该阶段。当然你使用线程计数可以实现，只是不够优雅。
所以我即：Java 多线程等待优雅的实现方式之Phaser同步屏障
之后再提供一个循环屏障，CyclicBarrier，更优雅的实现工具。
Maven依赖
可以依赖，也可以不依赖，只是代码要稍微多一些，最好添加。
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.7.15</version>
</dependency>
代码
不废话，上代码。
package com.huyi.csdn.tools;
import cn.hutool.core.thread.ThreadUtil;
import lombok.Getter;
import lombok.Setter;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.*;
/**
* @Program: csdn @ClassName: CyclicBarrierUtil @Author: huyi @Date: 2021-11-07 17:09 @Description:
* 循环屏障工具 @Version: V1.0
*/
public class CyclicBarrierUtil {
public static final ExecutorService executorService = Executors.newFixedThreadPool(50);
@Getter
@Setter
public static class SegmentedTask {
private Runnable start;
private Runnable middle;
private Runnable end;
public SegmentedTask(Runnable start, Runnable middle, Runnable end) {
this.start = start;
this.middle = middle;
this.end = end;
}
}
/**
* 提交任务
*
* @param tasks 参数
*/
public static void submit(List<SegmentedTask> tasks) {
CyclicBarrier cyclicBarrier = new CyclicBarrier(tasks.size() + 1);
try {
tasks.forEach(
x -> {
executorService.submit(
() -> {
try {
x.getStart().run();
cyclicBarrier.await();
x.getMiddle().run();
cyclicBarrier.await();
x.getEnd().run();
cyclicBarrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
});
});
cyclicBarrier.await();
System.out.println("初始任务已经全部完成");
cyclicBarrier.await();
System.out.println("中间任务已经全部完成");
cyclicBarrier.await();
System.out.println("最终任务已经全部完成");
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
}
public static void destroy() {
System.out.println("摧毁线程池");
executorService.shutdown();
}
}
代码说明
1、构造了一个分段任务实体类，成员有3段Runnable。
2、不同段的Runnable完成后会等待其他线程完成该段任务。
验证代码
public static void main(String[] args) {
Random random = new Random();
List<SegmentedTask> tasks = new ArrayList<>();
for (int i = 1; i < 11; i++) {
int finalI = i;
tasks.add(
new SegmentedTask(
() -> {
ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
System.out.println(
Thread.currentThread() + ":" + MessageFormat.format("第{0}军团已经开始推进！", finalI));
},
() -> {
ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
System.out.println(
Thread.currentThread() + ":" + MessageFormat.format("第{0}军团已经正在进攻！", finalI));
},
() -> {
ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
System.out.println(
Thread.currentThread() + ":" + MessageFormat.format("第{0}军团已经攻陷阵地！", finalI));
}));
}
CyclicBarrierUtil.submit(tasks);
ThreadUtil.sleep(35, TimeUnit.SECONDS);
CyclicBarrierUtil.destroy();
}
验证结果
E:\Java\jdk1.8.0_40\bin\java.exe "-javaagent:E:\Program Files\JetBrains\IntelliJ IDEA 2020.1.1\lib\idea_rt.jar=5831:E:\Program Files\JetBrains\IntelliJ IDEA 2020.1.1\bin" -Dfile.encoding=UTF-8 -classpath E:\Java\jdk1.8.0_40\jre\lib\charsets.jar;E:\Java\jdk1.8.0_40\jre\lib\deploy.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\access-bridge-64.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\cldrdata.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\dnsns.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\jaccess.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\jfxrt.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\localedata.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\nashorn.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunec.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunjce_provider.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunmscapi.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\sunpkcs11.jar;E:\Java\jdk1.8.0_40\jre\lib\ext\zipfs.jar;E:\Java\jdk1.8.0_40\jre\lib\javaws.jar;E:\Java\jdk1.8.0_40\jre\lib\jce.jar;E:\Java\jdk1.8.0_40\jre\lib\jfr.jar;E:\Java\jdk1.8.0_40\jre\lib\jfxswt.jar;E:\Java\jdk1.8.0_40\jre\lib\jsse.jar;E:\Java\jdk1.8.0_40\jre\lib\management-agent.jar;E:\Java\jdk1.8.0_40\jre\lib\plugin.jar;E:\Java\jdk1.8.0_40\jre\lib\resources.jar;E:\Java\jdk1.8.0_40\jre\lib\rt.jar;C:\Users\yi\IdeaProjects\csdn\target\classes;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-web\2.5.6\spring-boot-starter-web-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter\2.5.6\spring-boot-starter-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-logging\2.5.6\spring-boot-starter-logging-2.5.6.jar;C:\Users\yi\.m2\repository\ch\qos\logback\logback-classic\1.2.6\logback-classic-1.2.6.jar;C:\Users\yi\.m2\repository\ch\qos\logback\logback-core\1.2.6\logback-core-1.2.6.jar;C:\Users\yi\.m2\repository\org\apache\logging\log4j\log4j-to-slf4j\2.14.1\log4j-to-slf4j-2.14.1.jar;C:\Users\yi\.m2\repository\org\apache\logging\log4j\log4j-api\2.14.1\log4j-api-2.14.1.jar;C:\Users\yi\.m2\repository\org\slf4j\jul-to-slf4j\1.7.32\jul-to-slf4j-1.7.32.jar;C:\Users\yi\.m2\repository\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;C:\Users\yi\.m2\repository\org\yaml\snakeyaml\1.28\snakeyaml-1.28.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-json\2.5.6\spring-boot-starter-json-2.5.6.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.12.5\jackson-databind-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.12.5\jackson-annotations-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.12.5\jackson-core-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.12.5\jackson-datatype-jdk8-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.12.5\jackson-datatype-jsr310-2.12.5.jar;C:\Users\yi\.m2\repository\com\fasterxml\jackson\module\jackson-module-parameter-names\2.12.5\jackson-module-parameter-names-2.12.5.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-starter-tomcat\2.5.6\spring-boot-starter-tomcat-2.5.6.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-core\9.0.54\tomcat-embed-core-9.0.54.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-el\9.0.54\tomcat-embed-el-9.0.54.jar;C:\Users\yi\.m2\repository\org\apache\tomcat\embed\tomcat-embed-websocket\9.0.54\tomcat-embed-websocket-9.0.54.jar;C:\Users\yi\.m2\repository\org\springframework\spring-web\5.3.12\spring-web-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-beans\5.3.12\spring-beans-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-webmvc\5.3.12\spring-webmvc-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-aop\5.3.12\spring-aop-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-context\5.3.12\spring-context-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-expression\5.3.12\spring-expression-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-devtools\2.5.6\spring-boot-devtools-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot\2.5.6\spring-boot-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-autoconfigure\2.5.6\spring-boot-autoconfigure-2.5.6.jar;C:\Users\yi\.m2\repository\org\springframework\boot\spring-boot-configuration-processor\2.5.6\spring-boot-configuration-processor-2.5.6.jar;C:\Users\yi\.m2\repository\org\projectlombok\lombok\1.18.22\lombok-1.18.22.jar;C:\Users\yi\.m2\repository\org\slf4j\slf4j-api\1.7.32\slf4j-api-1.7.32.jar;C:\Users\yi\.m2\repository\org\springframework\spring-core\5.3.12\spring-core-5.3.12.jar;C:\Users\yi\.m2\repository\org\springframework\spring-jcl\5.3.12\spring-jcl-5.3.12.jar;C:\Users\yi\.m2\repository\cn\hutool\hutool-all\5.7.15\hutool-all-5.7.15.jar;C:\Users\yi\.m2\repository\com\google\guava\guava\31.0.1-jre\guava-31.0.1-jre.jar;C:\Users\yi\.m2\repository\com\google\guava\failureaccess\1.0.1\failureaccess-1.0.1.jar;C:\Users\yi\.m2\repository\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;C:\Users\yi\.m2\repository\com\google\code\findbugs\jsr305\3.0.2\jsr305-3.0.2.jar;C:\Users\yi\.m2\repository\org\checkerframework\checker-qual\3.12.0\checker-qual-3.12.0.jar;C:\Users\yi\.m2\repository\com\google\errorprone\error_prone_annotations\2.7.1\error_prone_annotations-2.7.1.jar;C:\Users\yi\.m2\repository\com\google\j2objc\j2objc-annotations\1.3\j2objc-annotations-1.3.jar com.huyi.csdn.tools.CyclicBarrierUtil
Thread[pool-1-thread-9,5,main]:第9军团已经开始推进！
Thread[pool-1-thread-10,5,main]:第10军团已经开始推进！
Thread[pool-1-thread-8,5,main]:第8军团已经开始推进！
Thread[pool-1-thread-3,5,main]:第3军团已经开始推进！
Thread[pool-1-thread-7,5,main]:第7军团已经开始推进！
Thread[pool-1-thread-5,5,main]:第5军团已经开始推进！
Thread[pool-1-thread-6,5,main]:第6军团已经开始推进！
Thread[pool-1-thread-4,5,main]:第4军团已经开始推进！
Thread[pool-1-thread-1,5,main]:第1军团已经开始推进！
Thread[pool-1-thread-2,5,main]:第2军团已经开始推进！
初始任务已经全部完成
Thread[pool-1-thread-4,5,main]:第4军团已经正在进攻！
Thread[pool-1-thread-6,5,main]:第6军团已经正在进攻！
Thread[pool-1-thread-5,5,main]:第5军团已经正在进攻！
Thread[pool-1-thread-8,5,main]:第8军团已经正在进攻！
Thread[pool-1-thread-7,5,main]:第7军团已经正在进攻！
Thread[pool-1-thread-9,5,main]:第9军团已经正在进攻！
Thread[pool-1-thread-1,5,main]:第1军团已经正在进攻！
Thread[pool-1-thread-2,5,main]:第2军团已经正在进攻！
Thread[pool-1-thread-3,5,main]:第3军团已经正在进攻！
Thread[pool-1-thread-10,5,main]:第10军团已经正在进攻！
中间任务已经全部完成
Thread[pool-1-thread-7,5,main]:第7军团已经攻陷阵地！
Thread[pool-1-thread-5,5,main]:第5军团已经攻陷阵地！
Thread[pool-1-thread-2,5,main]:第2军团已经攻陷阵地！
Thread[pool-1-thread-8,5,main]:第8军团已经攻陷阵地！
Thread[pool-1-thread-3,5,main]:第3军团已经攻陷阵地！
Thread[pool-1-thread-9,5,main]:第9军团已经攻陷阵地！
Thread[pool-1-thread-10,5,main]:第10军团已经攻陷阵地！
Thread[pool-1-thread-4,5,main]:第4军团已经攻陷阵地！
Thread[pool-1-thread-1,5,main]:第1军团已经攻陷阵地！
Thread[pool-1-thread-6,5,main]:第6军团已经攻陷阵地！
最终任务已经全部完成
摧毁线程池
Process finished with exit code 0
OK，完美。
来源：https://huyi-aliang.blog.csdn.net/article/details/121196047
0
投稿猜你喜欢
在WPF的DrawingContext对象中，提供了基本的绘制椭圆和矩形的API：DrawEllipse和DrawRectangle。但是，- 1.初始化顺序当Java创建一个对象时，系统先为该对象的所有实例属性分配内存（前提是该类已经被加载过了），接着程序开始对这些实例属性执行初始
- 传输层安全性协议（英语：Transport Layer Security，缩写作 TLS），及其前身安全套接层（Secure Sockets
- 本文介绍了idea 创建 maven web 工程流程(图文教程)，分享给大家，具体如下：1创建一个project工作区间；2.创建一个ma
- JAVA中获取文件MD5值的四种方法其实都很类似，因为核心都是通过JAVA自带的MessageDigest类来实现。获取文件MD5值主要分为
- 1.背景选择器（位于res/drawable/，使用方法：android:background=”@drawable/XXX”） <?
- 平时我们编写WinForm程序经常使用VS进行拖控件的方式，这样做虽然简单，但是无法深入了解WinForm程序的本质。其实，用记事本也可以编
- 废话不多说，直接给大家贴C#代码了。/// <summary>/// 执行存储过程，返回" 返回值"///
- 在编写程序时经常会使用到调用可执行程序的情况，本文将简单介绍C#调用exe的方法。在C#中，通过Process类来进行进程操作。 Proce
- 本文实例讲述了C#交错数组用法。分享给大家供大家参考。具体分析如下：交错数组是数组的数组，交错数组的元素可以是不同的尺寸和大小。交错数组有时
- 1、作用域1.1 作用域的作用作用域——scope通常来说，一段程序代码中所用到的名字并不总是有效/
- Http协议的重要性相信不用我多说了，HttpClient相比传统JDK自带的URLConnection，增加了易用性和灵活性（具体区别，日
- IDEA配置maven环境一、配置maven本地环境先参照以下博客进行maven的安装，配置IDEA 如何搭建maven 安装、下载、配置（
- 本文主要介绍了WPF中常用的鼠标事件、键盘事件以及注意事项，同时使用一个案例讲解了拓展事件。除此之外，本文还讲述如何用行为（Behavior
- Form1主窗体：public delegate void SetVisiableHandler();//定义委托类型private voi
- 一：需求当小数位很多的时候，小数位后面可能有一些多余的0并没有任何实际意义。所以在某些业务需求下可以去掉这些多余的0。例如：0.2000可以
- 一般来说在Android里要实现树形菜单，都是用ExpandableList(也有高手自己继承ListView或者LinearLayout来
- Java * 代理设计模式定义：为其他对象提供一种代理以控制对这个对象的访问。 * 使用java * 机制以巧妙的方式实现了代理模式的
- 引言♀ 小AD：明哥，我终于出了这口恶气了。♂ 明世隐：打爽了是吧。♀ 小AD：那必须的，打十盘我赢九盘，我随意。♂ 明世隐：那小朋友不是搞
- 幂等概述幂等性原本是数学上的概念，即使公式：f(x)=f(f(x)) 能够成立的数学性质。用在编程领域，则意为对同一个系统，使用同样的条件，
