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

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

2022-03-09 00:55剑客阿良_ALiang Java教程

异常是程序之中导致程序中断的一种指令流，异常一旦出现并且没有进行合理处理的话，那么程序就将中断执行，这篇文章综合介绍了异步线程监听与结果回调及异常捕获

前言

工作中是否遇到这样的场景？

1、需要异步线程执行，而且需要获取到线程执行返回的结果。

2、如果执行过程异常，可以按照自定义方式消费异常信息。

如果只是单纯的使用Callable可以实现，本文提供更加优雅的工具类。

Maven依赖

				?

									<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();

									  }

									}