SpringBoot创建自定义线程池

使用Java代码结合使用@Configuration进行配置

package com.gome.lmis.gop.common;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ThreadPoolExecutor;


@Configuration
@EnableAsync
public class ThreadPoolTaskConfig {
    

    
    private static final int corePoolSize = 20;

    
    private static final int maxPoolSize = 100;

    
    private static final int keepAliveTime = 10;

    
    private static final int queueCapacity = 200;

    private static final String threadNamePrefix = "Async-Service-";

    @Bean("taskExecutor")
    public ThreadPoolTaskExecutor taskExecutor(){
        ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setCorePoolSize(corePoolSize);
        threadPoolTaskExecutor.setMaxPoolSize(maxPoolSize);
        threadPoolTaskExecutor.setQueueCapacity(queueCapacity);
        threadPoolTaskExecutor.setKeepAliveSeconds(keepAliveTime);
        threadPoolTaskExecutor.setThreadNamePrefix(threadNamePrefix);
        //线程池对拒绝任务的处理策略
        //CallerRunsPolicy:由调用线程（提交任务的线程）处理该任务
        threadPoolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //初始化 必须初始化，否则报 ThreadPoolTaskExecutor not initialized
        threadPoolTaskExecutor.initialize();
        return threadPoolTaskExecutor;
    }


}