public class AsyncConfig implements AsyncConfigurer {
@Bean
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 设置线程池核心容量
executor.setCorePoolSize(10);
// 设置线程池最大容量
executor.setMaxPoolSize(20);
// 设置任务队列长度
executor.setQueueCapacity(200);
// 设置线程超时时间
executor.setKeepAliveSeconds(60);
// 设置线程名称前缀
executor.setThreadNamePrefix("taskExecutor-");
// 设置任务丢弃后的处理策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
return executor;
}
线程池的调用过程
- 核心线程池未满时: 接收任务,创建线程并执行该任务。
- 核心线程池已满时: 接收任务,任务进入等待队列等待。
- 核心线程池满且等待队列也满时: 接收任务,并创建线程执行该任务。
- 核心线程满,等待队列满且最大线程池也满时: 接收任务,按丢弃策略处理该任务。
|