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

代码说明

1、提交方法主要参数有，需要执行的Callable，结果的Consumer，异常的Consumer。其中Callable调整成Supplier也是没什么问题。

2、提供摧毁线程池方法。

执行结果

OK没什么问题。

总结

追求优雅是个好习惯。

如果本工具对你有用的话，请点个赞吧，这对作者很重要，谢谢。

关于Java 异步线程监听与结果回调及异常捕获总结分析的文章就介绍至此，更多相关Java 异步线程监听内容请搜索编程宝库以前的文章，希望大家多多支持编程宝库！

在使用BigDecimal的除法时，遇到一个鬼畜的问题，本以为的精度计算，结果使用返回0，当然最终发现还是使用姿势不对导致的，因此记录一下，避免后面重蹈覆辙 I. 问题抛 ...