diff --git a/ms-biz/src/main/java/com/ms/api/task/CheckAuditStatusTimeoutTaskService.java b/ms-biz/src/main/java/com/ms/api/task/CheckAuditStatusTimeoutTaskService.java index 211f773d..10a19dd9 100644 --- a/ms-biz/src/main/java/com/ms/api/task/CheckAuditStatusTimeoutTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/CheckMaterialBizWaitTaskService.java b/ms-biz/src/main/java/com/ms/api/task/CheckMaterialBizWaitTaskService.java index e1c6ffa4..54e837ce 100644 --- a/ms-biz/src/main/java/com/ms/api/task/CheckMaterialBizWaitTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditBufferTaskService.java b/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditBufferTaskService.java index 5c07dc64..9c32e830 100644 --- a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditBufferTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditProcessTaskService.java b/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditProcessTaskService.java index 8e8643dd..4a31813c 100644 --- a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialAuditProcessTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialBizProcessTaskService.java b/ms-biz/src/main/java/com/ms/api/task/MoveMaterialBizProcessTaskService.java index 41ed5d73..6e96cf79 100644 --- a/ms-biz/src/main/java/com/ms/api/task/MoveMaterialBizProcessTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/MovePublishBufferTaskService.java b/ms-biz/src/main/java/com/ms/api/task/MovePublishBufferTaskService.java index ca5f8351..9b9b8818 100644 --- a/ms-biz/src/main/java/com/ms/api/task/MovePublishBufferTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/ProcessMovePublishToPicTaskService.java b/ms-biz/src/main/java/com/ms/api/task/ProcessMovePublishToPicTaskService.java index bae16876..d2712a1a 100644 --- a/ms-biz/src/main/java/com/ms/api/task/ProcessMovePublishToPicTaskService.java +++ b/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(); diff --git a/ms-biz/src/main/java/com/ms/api/task/ProcessProductPublishTaskService.java b/ms-biz/src/main/java/com/ms/api/task/ProcessProductPublishTaskService.java index e3c519f0..47bea86a 100644 --- a/ms-biz/src/main/java/com/ms/api/task/ProcessProductPublishTaskService.java +++ b/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();