|
|
|
|
@ -67,19 +67,19 @@ public class ThreadPoolConfig {
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// @Bean
|
|
|
|
|
// @ConditionalOnMissingBean(ThreadPoolTaskScheduler.class)
|
|
|
|
|
// public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
|
|
|
|
|
// ThreadPoolTaskScheduler t = new ThreadPoolTaskScheduler();
|
|
|
|
|
//
|
|
|
|
|
// t.setPoolSize(core * 2 + 1); // 线程池大小
|
|
|
|
|
// t.setThreadNamePrefix("t-"); // 线程名称
|
|
|
|
|
// t.setAwaitTerminationSeconds(60); // 等待时长
|
|
|
|
|
// t.setWaitForTasksToCompleteOnShutdown(true); // 调度器shutdown被调用时等待当前被调度的任务完成
|
|
|
|
|
// t.initialize();
|
|
|
|
|
// log.info("创建了自定义线程池{}*,size:{}" , t.getThreadNamePrefix(), t.getPoolSize());
|
|
|
|
|
// return t;
|
|
|
|
|
// }
|
|
|
|
|
@Bean
|
|
|
|
|
@ConditionalOnMissingBean(ThreadPoolTaskScheduler.class)
|
|
|
|
|
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
|
|
|
|
|
ThreadPoolTaskScheduler t = new ThreadPoolTaskScheduler();
|
|
|
|
|
|
|
|
|
|
t.setPoolSize(core * 2 + 1); // 线程池大小
|
|
|
|
|
t.setThreadNamePrefix("t-"); // 线程名称
|
|
|
|
|
t.setAwaitTerminationSeconds(60); // 等待时长
|
|
|
|
|
t.setWaitForTasksToCompleteOnShutdown(true); // 调度器shutdown被调用时等待当前被调度的任务完成
|
|
|
|
|
t.initialize();
|
|
|
|
|
log.info("创建了自定义线程池{}*,size:{}" , t.getThreadNamePrefix(), t.getPoolSize());
|
|
|
|
|
return t;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|