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 3c15f4c..0625d5d 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
@@ -194,7 +194,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
 
 
         for (int i = 0; i < totalSegments; i++) {
-            log.info("调用第一次");
+            log.info("调用第{}次",i);
             String limit = " limit "+ i*pageSize + ","+pageSize;
             firstArray = count - (long) i *pageSize;
             if (firstArray>=pageSize){
diff --git a/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java b/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java
index 3037261..b3ce62a 100644
--- a/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java
+++ b/cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java
@@ -13,13 +13,14 @@ import com.muyu.domain.DataValue;
 import com.muyu.domain.taskenum.Weight;
 import com.muyu.task.feign.DataValueClient;
 import lombok.extern.log4j.Log4j2;
+import org.jetbrains.annotations.NotNull;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.HashMap;
 import java.util.List;
 
 @Log4j2
-public class SegmentTask implements Runnable {
+public class SegmentTask implements Runnable, Comparable<SegmentTask> {
 
 
     @Autowired
@@ -67,5 +68,9 @@ public class SegmentTask implements Runnable {
     }
 
 
+    @Override
+    public int compareTo(@NotNull SegmentTask o) {
+        return Integer.compare(o.weight.getWeight(), this.weight.getWeight());
+    }
 }