Kaynağa Gözat

定时任务

yangbq 1 ay önce
ebeveyn
işleme
2799bd8135

+ 29 - 0
src/main/java/com/sckj/project/config/ScheduledConfig.java

@@ -0,0 +1,29 @@
+package com.sckj.project.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+/**
+ * @Description 线程池配置
+ * @Author bqyang
+ * @Date 2025/2/20 15:41
+ * @Version 1.0
+ */
+@Configuration
+public class ScheduledConfig implements SchedulingConfigurer {
+
+    @Override
+    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
+        // 设置线程池大小
+        taskScheduler.setPoolSize(10);
+        // 线程名前缀
+        taskScheduler.setThreadNamePrefix("ScheduledTask-");
+        taskScheduler.initialize();
+        taskRegistrar.setTaskScheduler(taskScheduler);
+    }
+
+}
+

+ 3 - 1
src/main/java/com/sckj/project/task/ProjectTaskController.java

@@ -1,6 +1,7 @@
 package com.sckj.project.task;
 
 import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
 
 /**
  * @Description
@@ -8,9 +9,10 @@ import org.springframework.scheduling.annotation.Scheduled;
  * @Date 2025/3/4 15:02
  * @Version 1.0
  */
+@Component
 public class ProjectTaskController {
 
-    @Scheduled(cron = "0 0 0/1 * * ?")
+    @Scheduled(cron = "*/5 * * * * ?")
     public void task1(){
         System.out.println("task1");
     }