1、创建
@Configuration
public class ThreadPoolConfig {
/**
* 创建线程池
*/
@Bean(name = "threadPool")
public ThreadPoolTaskExecutor creatPool(){
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(16); // 核心线程数目
executor.setMaxPoolSize(64); // 指定最大线程数
executor.setQueueCapacity(320); // 队列中最大的数目
executor.setThreadNamePrefix("taskThreadPool_"); // 线程名称前缀
// rejection-policy：当pool已经达到max size的时候，如何处理新任务
// CALLER_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行
// 对拒绝task的处理策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.setKeepAliveSeconds(60); // 线程空闲后的最大存活时间
executor.initialize();
return executor;
}
}
2、使用
@Resource(name = "threadPool")
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
@Test
void jiecTest(){
threadPoolTaskExecutor.execute(()->{
for(int i=1;i<=200;i++){
System.out.println("线线程1："+i);
}
});
threadPoolTaskExecutor.execute(()->{
for(int i=200;i>0;i--){
System.out.println("线线程2："+i);
}
});
}
3、提交任务
无返回值的任务使用execute(Runnable)
有返回值的任务使用submit(Runnable)