调整各个任务并发池

ms-biz/src/main/java/com/ms/api/task/CheckAuditStatusTimeoutTaskService.java

@@ -45,7 +45,7 @@ public class CheckAuditStatusTimeoutTaskService extends TaskBaseService {
      * 同时开启任务处理数量
      */
     public int getCorePoolSiz() {
-        return 3;
+        return 4;
     }
 
     /**
@@ -70,7 +70,7 @@ public class CheckAuditStatusTimeoutTaskService extends TaskBaseService {
     }
 
     @Async("checkAuditStatusTimeoutTaskPool")
-    @Scheduled(fixedRate = 10000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/CheckMaterialBizWaitTaskService.java

@@ -38,7 +38,7 @@ public class CheckMaterialBizWaitTaskService extends TaskBaseService {
      * 同时开启任务处理数量
      */
     public int getCorePoolSiz() {
-        return 5;
+        return 10;
     }
 
     /**
@@ -63,7 +63,7 @@ public class CheckMaterialBizWaitTaskService extends TaskBaseService {
     }
 
     @Async("checkBizMaterialSuccessTaskPool")
-    @Scheduled(fixedRate = 10000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditBufferTaskService.java

@@ -71,7 +71,7 @@ public class MoveMaterialAuditBufferTaskService extends TaskBaseService {
     }
 
     @Async("moveMaterialAuditBufferPool")
-    @Scheduled(fixedRate = 10000)
+    @Scheduled(fixedRate =3000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditProcessTaskService.java

@@ -87,7 +87,7 @@ public class MoveMaterialAuditProcessTaskService extends TaskBaseService {
     }
 
     @Async("moveMaterialAuditProcessPool")
-    @Scheduled(fixedRate = 2000)
+    @Scheduled(fixedRate = 1000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/MoveMaterialBizProcessTaskService.java

@@ -81,7 +81,7 @@ public class MoveMaterialBizProcessTaskService extends TaskBaseService {
     }
 
     @Async("moveMaterialBizProcessTaskPool")
-    @Scheduled(fixedRate = 5000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/MovePublishBufferTaskService.java

@@ -83,7 +83,7 @@ public class MovePublishBufferTaskService extends TaskBaseService {
     }
 
     @Async("movePublishBufferTaskPool")
-    @Scheduled(fixedRate =5000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/ProcessMovePublishToPicTaskService.java

@@ -119,7 +119,7 @@ public class ProcessMovePublishToPicTaskService extends TaskBaseService {
      * 同时开启任务处理数量
      */
     public int getCorePoolSiz() {
-        return 5;
+        return 10;
     }
 
     /**
@@ -144,7 +144,7 @@ public class ProcessMovePublishToPicTaskService extends TaskBaseService {
     }
 
     @Async("processMovePublishToPicTaskPool")
-    @Scheduled(fixedRate = 10000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();

ms-biz/src/main/java/com/ms/api/task/ProcessProductPublishTaskService.java

@@ -132,7 +132,7 @@ public class ProcessProductPublishTaskService extends TaskBaseService {
      * 同时开启任务处理数量
      */
     public int getCorePoolSiz() {
-        return 5;
+        return 10;
     }
 
     /**
@@ -157,7 +157,7 @@ public class ProcessProductPublishTaskService extends TaskBaseService {
     }
 
     @Async("processProductPublishTaskPool")
-    @Scheduled(fixedRate = 10000)
+    @Scheduled(fixedRate = 2000)
     @Override
     public void runTask() {
         super.runTask();