这篇文章将为大家详细讲解有关Java多线程中如何实现Phaser同步屏障,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。
是否会遇到这样的场景,你向线程池提交了多个任务,你希望这批任务全部完成后能够反向通知你。
你可能会使用线程计数的方式,等到计数器累加到提交的线程数量,然后通知。emmm,不是不可以,只是不够优雅。本文提供优雅的实现方式,Phaser同步屏障。
也可以不依赖,本人习惯把代码简单化,使用了hutool,所以依赖只有这个。
<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 java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Phaser;
import java.util.concurrent.TimeUnit;
/**
* @Program: csdn @ClassName: PhaserUtil @Author: huyi @Date: 2021-11-06 21:03 @Description:
* 多线程监控回调工具 @Version: V1.0
*/
public class PhaserUtil {
public static final ExecutorService executorService = Executors.newFixedThreadPool(50);
public static class CustomPharser extends Phaser {
private final Runnable runnable;
public CustomPharser(Runnable runnable) {
this.runnable = runnable;
}
@Override
protected boolean onAdvance(int phase, int registeredParties) {
this.runnable.run();
return super.onAdvance(phase, registeredParties);
}
}
/**
* 提交任务以及完成后需要执行的内容
*
* @param tasks 任务
* @param complete 完成任务
*/
public static void submit(List<Runnable> tasks, Runnable complete) {
Phaser phaser = new CustomPharser(complete);
for (Runnable runnable : tasks) {
executorService.submit(
() -> {
phaser.register();
runnable.run();
System.out.println(Thread.currentThread().getName() + "完成任务!");
phaser.arriveAndAwaitAdvance();
});
}
}
/** 摧毁线程池 */
public static void destroy() {
System.out.println("摧毁线程池");
executorService.shutdown();
}
public static void main(String[] args) {
List<Runnable> tasks = new ArrayList<>();
Random random = new Random();
for (int i = 0; i < 10; i++) {
tasks.add(
() -> {
ThreadUtil.sleep(random.nextInt(10), TimeUnit.SECONDS);
});
}
submit(tasks, () -> System.out.println("所有任务已完成"));
ThreadUtil.sleep(20, TimeUnit.SECONDS);
destroy();
}
}
代码说明
1、提交任务执行的方式是Runnable也好,Callable也好,或者Consumer、Function等等,不影响,你可以看着调整。
2、完成后的Runnable也和第一点同理。
验证一下
OK,没什么问题。
关于Java多线程中如何实现Phaser同步屏障就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。