Java 多線程等待優雅的實現方式之Phaser同步屏障

Posted on by

前言

是否會遇到這樣的場景，你向線程池提交瞭多個任務，你希望這批任務全部完成後能夠反向通知你。

你可能會使用線程計數的方式，等到計數器累加到提交的線程數量，然後通知。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 多線程等待的資料請關註WalkonNet其它相關文章！

推薦閱讀：