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<TaskMapper, TaskInfo> 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<TaskMapper, TaskInfo> 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);
             });
         }