Spring线程池配置之AsyncConfigurer接口解读

//@EnableAsync
@Configuration
public class ThreadPoolConfig implements AsyncConfigurer {
    @Value("${thread.price.core-pool-size:17}")
    private int priceCorePoolSize;
    @Value("${thread.price.max-pool-size:30}")
    private int priceMaxPoolSize;
    @Value("${thread.price.queue-capacity:50}")
    private int priceQueueCapacity;
    @Value("${thread.price.keep-alive-seconds:60}")
    private int priceKeepAliveSeconds;

    @Bean
    public ThreadPoolTaskExecutor pricePoolTaskExecutor() {
        ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
        buildPriceParam(pool);
        return pool;
    }

    private void buildPriceParam(ThreadPoolTaskExecutor pool) {
        //CPU密集型
        pool.setCorePoolSize(priceCorePoolSize);
        pool.setMaxPoolSize(priceMaxPoolSize);
        pool.setQueueCapacity(priceQueueCapacity);
        pool.setKeepAliveSeconds(priceKeepAliveSeconds);
        pool.setThreadNamePrefix("price-calculation-thread-pool-");
        pool.setWaitForTasksToCompleteOnShutdown(true);
        pool.setAwaitTerminationSeconds(60);
        pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        pool.initialize();
    }

    /**
     * 注解@Async默认的线程池(通常需要与@EnableAsync注解一起使用)
     *
     * @return
     */
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
        build(pool);
        return pool;
    }

    /**
     * 用于处理异步任务执行中抛出的未捕获异常
     *
     * @return
     */
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }

    /**
     * 默认线程池配置
     *
     * @param pool
     */
    private void build(ThreadPoolTaskExecutor pool) {
        pool.setCorePoolSize(5);
        pool.setMaxPoolSize(10);
        pool.setQueueCapacity(50);
        pool.setKeepAliveSeconds(60);
        pool.setThreadNamePrefix("async-task-thread-pool-");
        pool.setWaitForTasksToCompleteOnShutdown(true);
        pool.setAwaitTerminationSeconds(60);
        pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        pool.initialize();
    }
}