Java 异步线程监听与结果回调及异常捕获总结分析
作者:剑客阿良_ALiang 时间:2021-10-14 01:23:40
前言
工作中是否遇到这样的场景?
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没什么问题。
来源:https://huyi-aliang.blog.csdn.net/article/details/121049222
标签:Java,异步线程监听,结果回调,异常捕获
0
投稿
猜你喜欢
SpringBoot中实现分布式的Session共享的详细教程
2023-08-23 18:23:43
mybatis初始化SqlSessionFactory失败的几个原因分析
2021-06-17 11:13:44
Java十分钟精通类 封装 继承
2023-11-25 10:55:58
java线程之join方法的使用介绍
2023-01-15 12:18:40
java处理数据库不支持的emoji表情符问题解决
2021-08-21 00:16:58
MyBatis常用的jdbcType数据类型
2023-09-18 19:09:35
在SpringBoot中通过jasypt进行加密解密的方法
2023-11-15 21:29:23
springboot远程debug调试全过程
2023-11-25 07:05:56
IDEA(jetbrain通用)使用教程图解
2023-04-15 04:05:49
Mybatis批量操作sql写法示例(批量新增、更新)
2022-12-06 15:19:16
深入理解java内置锁(synchronized)和显式锁(ReentrantLock)
2023-11-19 00:10:57
SpringBoot集成RabbitMQ的方法(死信队列)
2023-06-10 15:12:06
springboot-dubbo cannot be cast to问题及解决
2022-06-27 14:46:51
IDEA解决springboot热部署失效问题(推荐)
2023-08-12 10:40:49
SpringMVC RESTFul及REST架构风格介绍
2021-09-30 05:05:33
完美解决SpringCloud-OpenFeign使用okhttp替换不生效问题
2023-07-03 11:27:25
详解JVM之运行时常量池
2022-08-04 03:41:03
如何用C#实现SAGA分布式事务
2022-11-29 20:34:49
Springboot项目引入druid安装部署使用教程
2023-07-28 01:39:25
DevExpress实现GridView当无数据行时提示消息
2023-08-23 04:13:33