Spring线程池ThreadPoolTaskExecutor

1. 线程池配置

@Configuration
public class TaskExecutorConfig implements AsyncConfigurer {

    @Value("${async.core.pool.size:10}") //核心线程数
    private Integer corePoolSize;

    @Value("${async.max.pool.size:40}") //最大线程数
    private Integer maxPoolSize;

    @Value("${async.queue.capacity:2000}") //任务队列
    private Integer queueCapacity;

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(corePoolSize);
        taskExecutor.setMaxPoolSize(maxPoolSize);
        taskExecutor.setQueueCapacity(queueCapacity);
        taskExecutor.setThreadNamePrefix("async-service-"); //线程池的前缀名称
        taskExecutor.initialize();
        return taskExecutor;
    }

（1）ThreadPoolTaskExecutor实际上就是通过initialize()方法实现对ThreadPoolExecutor的包装。

int c = ctl.get();
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        if (isRunning(c) && workQueue.offer(command)) {
            int recheck = ctl.get();
            if (! isRunning(recheck) && remove(command))
                reject(command);
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }
        else if (!addWorker(command, false))
            reject(command);

（2）处理流程：源码如上，①判断核心线程数是否已满，没满则创建一条线程并执行任务；②若核心线程数已满，则判断任务队列是否已满，没满则创建一条线程放在队列等待执行；③若任务队列已满，则判断最大线程数是否已满，没满则创建一条线程并执行任务，否则执行拒绝策略。即优先核心线程，阻塞队列次之，最后才是非核心线程。

2. @Async注解

（1）@Async作用在方法上，表示这个方法是个异步方法；作用在类上，表示这个类里的所有方法都是异步方法。

（2）使用@Async注解，需要在启动类上加上@EnableAsync注解，否则多线程不生效。