From a292659e839334bcffc8099fffb3546c9decf151 Mon Sep 17 00:00:00 2001 From: qiushengjie Date: Sun, 17 Sep 2023 16:42:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=90=AC=E5=AE=B6=E8=B0=83=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ms/api/common/TaskBaseService.java | 26 +++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/ms-biz/src/main/java/com/ms/api/common/TaskBaseService.java b/ms-biz/src/main/java/com/ms/api/common/TaskBaseService.java index 3385fd22..1d0b6ad4 100644 --- a/ms-biz/src/main/java/com/ms/api/common/TaskBaseService.java +++ b/ms-biz/src/main/java/com/ms/api/common/TaskBaseService.java @@ -39,7 +39,7 @@ public abstract class TaskBaseService implements TaskHandler { } public void runTask() { - while (true) { +// while (true) { try { setLogId(); if (isPoolFull()) { @@ -52,18 +52,18 @@ public abstract class TaskBaseService implements TaskHandler { log.error("任务异常退出, 任务池 " + getTaskExecutorName(), e); } - if(!isCirculate()){ - log.info("任务不循环,退出"); - return; - } - - try { - Thread.sleep(getIntervalTimeSecond()); - } catch (Throwable e) { - log.error("循环间隔异常"); - } - log.info("进入下一次循环"); - } +// if(!isCirculate()){ +// log.info("任务不循环,退出"); +// return; +// } +// +// try { +// Thread.sleep(getIntervalTimeSecond()); +// } catch (Throwable e) { +// log.error("循环间隔异常"); +// } +// log.info("进入下一次循环"); +// } } private void setLogId() {