Java 多线程等待优雅的实现方式之Phaser同步屏障

前言

是否会遇到这样的场景，你向线程池提交了多个任务，你希望这批任务全部完成后能够反向通知你。

你可能会使用线程计数的方式，等到计数器累加到提交的线程数量，然后通知。emmm，不是不可以，只是不够优雅。本文提供优雅的实现方式，phaser同步屏障。

maven依赖

也可以不依赖，本人习惯把代码简单化，使用了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，没什么问题。

总结

其实我一直想分享一些可以让读者工作中能用到的东西，想到牧神记里面的一句话，圣人之道，无非就是百姓日用。emmmm，又废话了。

分享一下：

没必要的事就不做，必要的事就尽快做。---冰果

如果本文对你有用，请不要吝啬你的赞，谢谢。

以上就是java 多线程等待优雅的实现方式之phaser同步屏障的详细内容，更多关于java 多线程等待的资料请关注其它相关文章！