From 7d278a497c7e38389a9ea11d23fe019b5cd11ecc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com> Date: Sun, 8 Sep 2024 09:20:33 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=BA=BF=E7=A8=8B=E6=B1=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/muyu/service/impl/TaskServiceImpl.java | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index ba4db3b..1cd5644 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -20,7 +20,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.List; -import static com.muyu.task.PriorityThreadPool.executeUrgently; +import static com.muyu.task.PriorityThreadPool.*; /** @@ -187,11 +187,10 @@ public class TaskServiceImpl extends ServiceImpl implement Long basicId = Long.valueOf(taskOutputInfo.getBasicId()); Long tableId = Long.valueOf(taskOutputInfo.getTableId()); - Integer weigh = taskInfo.getWeigh(); if(taskInfo.getWeigh() == 4){ - log.info("执行高级任务"); + log.info("执行紧急任务"); Long finalDatabaseId = databaseId; String finalSql = sql; log.info("sql为{}",finalSql); @@ -204,25 +203,25 @@ public class TaskServiceImpl extends ServiceImpl implement log.info("执行高级任务"); Long finalDatabaseId = databaseId; String finalSql = sql; - executeUrgently(() -> { + executeHigh(() -> { selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); }); } if(taskInfo.getWeigh() == 2){ - log.info("执行高级任务"); + log.info("执行中级任务"); Long finalDatabaseId = databaseId; String finalSql = sql; - executeUrgently(() -> { + executeMedium(() -> { selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); }); } if(taskInfo.getWeigh() == 1){ - log.info("执行高级任务"); + log.info("执行低级任务"); Long finalDatabaseId = databaseId; String finalSql = sql; - executeUrgently(() -> { + executeLow(() -> { selectAndAdd(count, finalDatabaseId, basicId, finalSql, tableId,newAndOldMap); }); }