feat: 开启 Spring 异步和定时任务

Author: cadecode

application/src/main/java/top/cadecode/uniboot/UniBootApplication.java

@@ -1,21 +1,18 @@
 package top.cadecode.uniboot;
 
-import com.dtp.core.spring.EnableDynamicTp;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;
 
 /**
  * 启动类
  */
-@EnableDynamicTp
 @MapperScan("top.cadecode.**.mapper")
 @EnableAspectJAutoProxy(exposeProxy = true)
-@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
+@SpringBootApplication
 public class UniBootApplication extends SpringBootServletInitializer {
 
     public static void main(String[] args) {
@@ -26,5 +23,4 @@ public static void main(String[] args) {
     protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
         return application.sources(UniBootApplication.class);
     }
-
 }

application/src/main/resources/application.yml

@@ -57,7 +57,7 @@ spring:
       monitorInterval: 10
       executors:
         - threadPoolName: asyncExecutor
-          thread-name-prefix: asyncExecutor
+          thread-name-prefix: asyncExecutor-
           corePoolSize: 6
           maximumPoolSize: 8
           queueCapacity: 1000

framework/src/main/java/top/cadecode/uniboot/framework/config/ThreadPoolConfig.java

@@ -1,11 +1,14 @@
 package top.cadecode.uniboot.framework.config;
 
 import com.dtp.core.DtpRegistry;
+import com.dtp.core.spring.EnableDynamicTp;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.SchedulingConfigurer;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
@@ -18,6 +21,9 @@
  * @date 2023/3/15
  */
 @Slf4j
+@EnableDynamicTp
+@EnableAsync
+@EnableScheduling
 @Configuration
 public class ThreadPoolConfig {
 
@@ -28,7 +34,7 @@ public class ThreadPoolConfig {
     public ThreadPoolTaskScheduler taskScheduler() {
         ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
         scheduler.setPoolSize(6);
-        scheduler.setThreadNamePrefix("taskScheduler");
+        scheduler.setThreadNamePrefix("taskScheduler-");
         scheduler.setWaitForTasksToCompleteOnShutdown(true);
         scheduler.setAwaitTerminationSeconds(5);
         return scheduler;