聊聊TaskExecutor的spring托管

bovenson 發(fā)布于2019-08-15 12:24 / 1285人閱讀

摘要：序本文主要簡(jiǎn)述下如何設(shè)置的。實(shí)例使用托管的好處就是可以在容器啟動(dòng)或銷毀的時(shí)候做些準(zhǔn)備或清理動(dòng)作。分別可以用及來指定。默認(rèn)尋找的命名為或者的無參方法，這里沒有配置，默認(rèn)調(diào)用的是的方法。

序

本文主要簡(jiǎn)述下如何設(shè)置TaskExecutor的Thread.UncaughtExceptionHandler。

實(shí)例

    @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;
    }

使用spring托管TaskExecutor的好處就是可以在spring容器啟動(dòng)或銷毀的時(shí)候做些準(zhǔn)備或清理動(dòng)作。分別可以用initMethod及destroyMethod來指定。
destroyMethod默認(rèn)尋找public的命名為close或者shutdown的無參方法，這里沒有配置，默認(rèn)調(diào)用的是ThreadPoolTaskScheduler的shutdown方法。

配置Thread.UncaughtExceptionHandler

spring默認(rèn)會(huì)給async的線程池配SimpleAsyncUncaughtExceptionHandler，具體見spring-context-4.3.9.RELEASE-sources.jar!/org/springframework/scheduling/annotation/AsyncAnnotationAdvisor.java

不過自己配置的taskExecutor就沒有這個(gè)福利了，需要自己配置，如下：

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

這樣就大功告成了