From a2c2d9e29e37654b4dbe55f40136d511d57fa2b5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com> Date: Fri, 6 Sep 2024 17:20:24 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=81=94=E6=9F=A5=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/muyu/service/impl/TaskServiceImpl.java | 2 +- .../src/main/java/com/muyu/task/SegmentTask.java | 7 ++++++- 2 files changed, 7 insertions(+), 2 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 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 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 { @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()); + } }