多个定时任务设置

src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java

@@ -0,0 +1,11 @@
+package cn.chjyj.szwh.service;
+
+/**
+ * 商品定时任务接口
+ */
+public interface GoodsTaskService {
+    /**
+     * 获取撤销委托信息
+     */
+    public void getRevocationGoods();
+}

src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java

@@ -0,0 +1,13 @@
+package cn.chjyj.szwh.service.impl;
+
+import cn.chjyj.szwh.service.GoodsTaskService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class GoodsTaskServiceImpl implements GoodsTaskService {
+    @Override
+    public void getRevocationGoods() {
+        String st="同步被撤销商品信息";
+        System.out.println(st);
+    }
+}

src/main/java/cn/chjyj/szwh/task/SzwhScheduled.java

@@ -1,5 +1,6 @@
 package cn.chjyj.szwh.task;
 
+import cn.chjyj.szwh.service.GoodsTaskService;
 import org.springframework.context.annotation.Bean;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.annotation.EnableScheduling;
@@ -13,8 +14,18 @@ import java.time.LocalDateTime;
  * 多个定时任务启动
  */
 @Component
-@EnableScheduling
+//@EnableScheduling
 public class SzwhScheduled {
+    private GoodsTaskService goodsTaskService;
+
+    public GoodsTaskService getGoodsTaskService() {
+        return goodsTaskService;
+    }
+
+    public void setGoodsTaskService(GoodsTaskService goodsTaskService) {
+        this.goodsTaskService = goodsTaskService;
+    }
+
     @Bean
     public TaskScheduler taskScheduler(){
         ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
@@ -25,18 +36,20 @@ public class SzwhScheduled {
     /**
      * 查询查询撤销商品的信息
      */
-    @Scheduled(cron = "0/20 * * * * ?")
+    //@Scheduled(cron = "0/20 * * * * ?")
     public void queryRevocationGoods(){
         String curName = Thread.currentThread().getName() ;
         System.out.println("当前时间:"+ LocalDateTime.now()+"  任务queryRevocationGoods对应的线程名: "+curName);
+
         try {
+            goodsTaskService.getRevocationGoods();
             Thread.sleep(1000);
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
 
-    @Scheduled(cron = "0/5 * * * * ?")
+    //@Scheduled(cron = "0/5 * * * * ?")
     public void execute2(){
         String curName = Thread.currentThread().getName() ;
         System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute2对应的线程名: "+curName);