diff --git a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java index cc39b96..b4d8bbf 100644 --- a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java +++ b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java @@ -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; + } }