Java 异步线程监听 Java 异步线程监听与结果回调及异常捕获总结分析

        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.7.15</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>31.0.1-jre</version>
        </dependency>

package com.huyi.csdn.tools;
 
import cn.hutool.core.thread.ThreadUtil;
import com.google.common.util.concurrent.*;
import org.checkerframework.checker.nullness.qual.Nullable;
import org.springframework.scheduling.concurrent.CustomizableThreadFactory;
 
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
 
/**
 * @Program: csdn @ClassName: AsyncListenUtil @Author: huyi @Date: 2021-10-30 11:48 @Description:
 * 异步线程监听回调工具 @Version: V1.0
 */
public class AsyncListenUtil {
  public static final ExecutorService executorService =
      Executors.newFixedThreadPool(10, new CustomizableThreadFactory("LISTEN-"));
  public static final ListeningExecutorService listeningExecutorService =
      MoreExecutors.listeningDecorator(executorService);
 
  /**
   * 提交任务
   *
   * @param work Callable需要线程执行的内容
   * @param consumer 结果消费
   * @param errorConsumer 异常消费
   * @param <T> 泛型
   */
  public static <T> void submit(
      Callable<T> work, Consumer<T> consumer, Consumer<Throwable> errorConsumer) {
    ListenableFuture<T> listenableFuture = listeningExecutorService.submit(work);
    Futures.addCallback(
        listenableFuture,
        new FutureCallback<T>() {
          @Override
          public void onSuccess(@Nullable T s) {
            consumer.accept(s);
          }
 
          @Override
          public void onFailure(Throwable throwable) {
            errorConsumer.accept(throwable);
          }
        },
        listeningExecutorService);
  }
 
  /** 摧毁线程池 */
  public static void destroy() {
    System.out.println("摧毁线程池");
    executorService.shutdown();
  }
 
  public static void main(String[] args) {
    AsyncListenUtil.submit(
        () -> {
          // todo 需要执行的内容
          ThreadUtil.sleep(10, TimeUnit.SECONDS);
          return "I finished my work";
        },
        result -> {
          // todo 结果处理
          System.out.println("listen get :" + result);
        },
        throwable -> {
          // todo 异常处理
          System.out.println(throwable.getMessage());
        });
    ThreadUtil.sleep(20, TimeUnit.SECONDS);
    destroy();
  }
}