前言
工作中是否遇到这样的场景？
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没什么问题。
总结
追求优雅是个好习惯。
如果本工具对你有用的话，请点个赞吧，这对作者很重要，谢谢。
