前言
工作中是否遇到這樣的場景？
1、需要異步線程執(zhí)行，而且需要獲取到線程執(zhí)行返回的結(jié)果。
2、如果執(zhí)行過程異常，可以按照自定義方式消費(fèi)異常信息。
如果只是單純的使用Callable可以實現(xiàn)，本文提供更加優(yōu)雅的工具類。
Maven依賴
|
1
2
3
4
5
6
7
8
9
10
11
|
<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> |
代碼
不廢話，上代碼。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
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: * 異步線程監(jiān)聽回調(diào)工具 @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); /** * 提交任務(wù) * * @param work Callable需要線程執(zhí)行的內(nèi)容 * @param consumer 結(jié)果消費(fèi) * @param errorConsumer 異常消費(fèi) * @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 需要執(zhí)行的內(nèi)容 ThreadUtil.sleep(10, TimeUnit.SECONDS); return "I finished my work"; }, result -> { // todo 結(jié)果處理 System.out.println("listen get :" + result); }, throwable -> { // todo 異常處理 System.out.println(throwable.getMessage()); }); ThreadUtil.sleep(20, TimeUnit.SECONDS); destroy(); }} |
代碼說明
1、提交方法主要參數(shù)有，需要執(zhí)行的Callable，結(jié)果的Consumer，異常的Consumer。其中Callable調(diào)整成Supplier也是沒什么問題。
2、提供摧毀線程池方法。
執(zhí)行結(jié)果
OK沒什么問題。
總結(jié)
追求優(yōu)雅是個好習(xí)慣。
如果本工具對你有用的話，請點個贊吧，這對作者很重要，謝謝。
到此這篇關(guān)于Java 異步線程監(jiān)聽與結(jié)果回調(diào)及異常捕獲總結(jié)分析的文章就介紹到這了,更多相關(guān)Java 異步線程監(jiān)聽內(nèi)容請搜索服務(wù)器之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持服務(wù)器之家！
原文鏈接：https://huyi-aliang.blog.csdn.net/article/details/121049222
