From 47fdfa7637660df6183df1ed5222ebbd4f2de9f6 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:33:40 +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 --- .../src/main/java/com/muyu/service/impl/TaskServiceImpl.java | 2 ++ cloud-task-server/src/main/java/com/muyu/task/SegmentTask.java | 2 ++ 2 files changed, 4 insertions(+) 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 0625d5d..8c36f63 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 @@ -202,7 +202,9 @@ public class TaskServiceImpl extends ServiceImpl implement } String limitSelect = sql + limit; SegmentTask segmentTask = new SegmentTask(limitSelect, tableId, basicId,newAndOldMap, Weight.getWeight(weigh)); + log.info("创建任务添加到队列当中"); queue.add(segmentTask); + log.info("添加到queue里成功"); } // 启动线程池执行任务 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 b3ce62a..7327183 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 @@ -42,6 +42,8 @@ public class SegmentTask implements Runnable, Comparable { @Override public void run() { + + log.info("开始执行任务：" + basicId + " " + sql + " " + weight + " " + tableId, tableId); // 查询数据 Result>> tableValue = dataValueClient.findTableValue(basicId, sql); List> data = tableValue.getData();