feat: 配置定时线程池线程数、关闭前等待时间

Author: cadecode

framework/src/main/java/com/github/cadecode/uniboot/framework/config/ThreadPoolConfig.java

@@ -2,10 +2,10 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.dromara.dynamictp.core.thread.DtpExecutor;
 import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.core.task.AsyncTaskExecutor;
 import org.springframework.scheduling.annotation.AsyncConfigurer;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
@@ -28,18 +28,21 @@
 @Configuration
 public class ThreadPoolConfig {
 
-    private final AsyncTaskExecutor asyncExecutor;
+    private final DtpExecutor asyncExecutor;
 
     /**
      * Spring 定时任务线程池
      */
     @Bean(name = "taskScheduler", destroyMethod = "shutdown")
     public ThreadPoolTaskScheduler taskScheduler() {
         ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
-        scheduler.setPoolSize(6);
+        scheduler.setPoolSize(Runtime.getRuntime().availableProcessors());
         scheduler.setThreadNamePrefix("taskScheduler-");
         scheduler.setWaitForTasksToCompleteOnShutdown(true);
-        scheduler.setAwaitTerminationSeconds(5);
+        scheduler.setAwaitTerminationSeconds(300);
+        scheduler.setErrorHandler(throwable -> {
+            log.error("Scheduled task execute fail,", throwable);
+        });
         return scheduler;
     }