SpringBoot集成Spring task例子工程

Author: nicky

springboot-scheduler-task/src/main/java/com/example/springboot/scheduler/ApplicationRuner.java

@@ -0,0 +1,64 @@
+package com.example.springboot.scheduler;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.support.CronTrigger;
+import org.springframework.scheduling.support.PeriodicTrigger;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.concurrent.ScheduledFuture;
+
+/**
+ * <pre>
+ *
+ * </pre>
+ *
+ * <pre>
+ * @author mazq
+ * 修改记录
+ *    修改后版本:     修改人：  修改日期: 2020/07/22 13:36  修改内容:
+ * </pre>
+ */
+@Component
+@Slf4j
+public class ApplicationRuner implements CommandLineRunner {
+
+    @Autowired
+    private ThreadPoolTaskScheduler taskScheduler;
+    @Autowired
+    private CronTrigger cronTrigger;
+    @Autowired
+    @Qualifier("periodicTrigger")
+    private PeriodicTrigger periodicTrigger;
+
+    @Override
+    public void run(String... args) throws Exception {
+//        taskScheduler.schedule(new TaskThread(Thread.currentThread().getName()), new Date());
+//        taskScheduler.scheduleWithFixedDelay(new TaskThread(Thread.currentThread().getName()), 1000);
+//        taskScheduler.scheduleWithFixedDelay(new TaskThread(Thread.currentThread().getName()), new Date(), 1000);
+//        taskScheduler.scheduleAtFixedRate(new TaskThread("Thread.currentThread().getName()), new Date(), 2000);
+//        taskScheduler.scheduleAtFixedRate(new TaskThread(Thread.currentThread().getName()), 2000);
+          taskScheduler.schedule(new TaskThread(Thread.currentThread().getName()), cronTrigger);
+//        taskScheduler.schedule(new TaskThread(Thread.currentThread().getName()), periodicTrigger);
+    }
+
+    class TaskThread implements Runnable {
+        String name;
+        public TaskThread(String name) {
+            this.name = name;
+        }
+        @Override
+        public void run() {
+            log.info("task is run on thread :[{}],current time:[{}]",name,
+                    LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+        }
+    }
+}

springboot-scheduler-task/src/main/java/com/example/springboot/scheduler/configuration/TaskSchedulerConfiguration.java

@@ -4,6 +4,10 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.support.CronTrigger;
+import org.springframework.scheduling.support.PeriodicTrigger;
+
+import java.util.concurrent.TimeUnit;
 
 /**
  * <pre>
@@ -25,7 +29,26 @@ public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
         ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
         threadPoolTaskScheduler.setPoolSize(5);
         threadPoolTaskScheduler.setThreadNamePrefix("ThreadPoolTaskScheduler");
+        threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
+        threadPoolTaskScheduler.setAwaitTerminationSeconds(60);
         return threadPoolTaskScheduler;
     }
 
+    @Bean
+    public CronTrigger cronTrigger() {
+        return new CronTrigger("0/3 * * * * ?");
+    }
+
+    @Bean("periodicTrigger")
+    public PeriodicTrigger periodicTrigger() {
+        return new PeriodicTrigger(2000, TimeUnit.MICROSECONDS);
+    }
+
+    @Bean("periodicFixedDelayTrigger")
+    public PeriodicTrigger periodicFixedDelayTrigger() {
+        PeriodicTrigger periodicTrigger = new PeriodicTrigger(2000, TimeUnit.MICROSECONDS);
+        periodicTrigger.setFixedRate(true);
+        periodicTrigger.setInitialDelay(1000);
+        return periodicTrigger;
+    }
 }

springboot-scheduler-task/src/main/java/com/example/springboot/scheduler/service/TaskService.java

@@ -22,7 +22,7 @@
 @Slf4j
 public class TaskService {
 
-    @Scheduled(fixedDelay = 3000)
+    @Scheduled(fixedDelay = 10000)
     public void testFixedDelay() {
         log.info("fixedDelay test,thread name:[{}],execute time:[{}]",Thread.currentThread().getName(),
                 LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -35,7 +35,7 @@ public void testCron(){
                 LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
     }
 
-    @Scheduled(fixedRate = 5000)
+    @Scheduled(initialDelay = 5000, fixedRate = 10000)
     public void testFixedRate() {
         log.info("fixedRate test,thread name:[{}],execute time:[{}]",Thread.currentThread().getName(),
                 LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));

springboot-scheduler-task/src/main/resources/application.yml

@@ -0,0 +1,10 @@
+spring:
+  task:
+    scheduling:
+      pool:
+        size: 5
+      thread-name-prefix: ThreadPoolTaskScheduler-
+    execution:
+      pool:
+        allow-core-thread-timeout: true
+