資訊專欄INFORMATION COLUMN
摘要：序本文主要簡述下如何設(shè)置的。實例使用托管的好處就是可以在容器啟動或銷毀的時候做些準備或清理動作。分別可以用及來指定。默認尋找的命名為或者的無參方法，這里沒有配置，默認調(diào)用的是的方法。
序
本文主要簡述下如何設(shè)置TaskExecutor的Thread.UncaughtExceptionHandler。
實例 @Bean
protected ThreadPoolTaskScheduler taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(50);
executor.setQueueCapacity(100);
executor.setThreadNamePrefix("demo-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.initialize();
return executor;
}
配置Thread.UncaughtExceptionHandler使用spring托管TaskExecutor的好處就是可以在spring容器啟動或銷毀的時候做些準備或清理動作。分別可以用initMethod及destroyMethod來指定。
destroyMethod默認尋找public的命名為close或者shutdown的無參方法，這里沒有配置，默認調(diào)用的是ThreadPoolTaskScheduler的shutdown方法。
spring默認會給async的線程池配SimpleAsyncUncaughtExceptionHandler，具體見spring-context-4.3.9.RELEASE-sources.jar!/org/springframework/scheduling/annotation/AsyncAnnotationAdvisor.java
不過自己配置的taskExecutor就沒有這個福利了，需要自己配置，如下：
final Thread.UncaughtExceptionHandler uncaughtExceptionHandler = new Thread.UncaughtExceptionHandler() {
@Override
public void uncaughtException(Thread t, Throwable e) {
//do what you want
}
};
ThreadFactoryBuilder threadFactoryBuilder = new ThreadFactoryBuilder();
threadFactoryBuilder.setNameFormat("demo-%d");
threadFactoryBuilder.setUncaughtExceptionHandler(uncaughtExceptionHandler);
executor.setThreadFactory(threadFactoryBuilder.build());
這樣就大功告成了
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/67917.html
摘要：序本文主要聊聊中的注解。這里從獲取注解有個可以標注使用哪個，這里的就是尋找這個標識。推薦注解指定，然后的返回，讓它去尋找默認的自己應(yīng)用里頭都默認定義一個給托管 序 本文主要聊聊spring中的async注解。 AsyncConfigurer @EnableAsync(proxyTargetClass = true) @Configuration public class AsyncCo...
摘要：注意這時中結(jié)果為，即將原來的替換成，所以直接返回線程池執(zhí)行的結(jié)果。提醒中的是你業(yè)務(wù)代碼執(zhí)行的步驟。所以異步異常處理和同步相同，在這段請求中處理。比多，調(diào)用時間即發(fā)起之前。正是請求被異步化，從而使得能，即。 用法 @GetMapping(/ddd) public Callable process() { return () -> { Thread.sleep(...
摘要：下面我們稍稍改下代碼來證實一下這次我讓任務(wù)執(zhí)行的時間等于，大于條線程總間隔時間來耗盡線程池中的線程。 1.開篇 在Spring定時任務(wù)@Scheduled注解使用方式淺窺這篇文章里面提及過，spring的定時任務(wù)默認是單線程的，他在某些場景下會造成堵塞，那么如果我們想讓每一個任務(wù)都起一條線程去執(zhí)行呢？ 2.使用@Async 我們可以使用Spring的@Async注解十分容易的實現(xiàn)多線程...
摘要：第三個就是比較重點的內(nèi)容，在有贊的實踐。第四部分是將實時計算化，界面化的一些實踐。二有贊實時平臺架構(gòu)有贊的實時平臺架構(gòu)呢有幾個主要的組成部分。實時平臺提供了集群管理，項目管理，任務(wù)管理和報警監(jiān)控的功能。。 一、前言 這篇主要由五個部分來組成： 首先是有贊的實時平臺架構(gòu)。 其次是在調(diào)研階段我們?yōu)槭裁催x擇了 Flink。在這個部分，主要是 Flink 與 Spark 的 structure...
摘要：第三個就是比較重點的內(nèi)容，在有贊的實踐。第四部分是將實時計算化，界面化的一些實踐。二有贊實時平臺架構(gòu)有贊的實時平臺架構(gòu)呢有幾個主要的組成部分。實時平臺提供了集群管理，項目管理，任務(wù)管理和報警監(jiān)控的功能。。 一、前言 這篇主要由五個部分來組成： 首先是有贊的實時平臺架構(gòu)。 其次是在調(diào)研階段我們?yōu)槭裁催x擇了 Flink。在這個部分，主要是 Flink 與 Spark 的 structure...
閱讀 2274·2021-11-25 09:43
閱讀 3147·2021-10-14 09:42
閱讀 3497·2021-10-12 10:12
閱讀 1580·2021-09-07 10:17
閱讀 1912·2019-08-30 15:54
閱讀 3197·2019-08-30 15:54
閱讀 1570·2019-08-30 15:53
閱讀 1930·2019-08-29 11:21
