From 6fdd7965e59094c67b21d34057105c1cf54826dc Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Mon, 22 Jan 2024 11:28:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../timer/impl/HutoolTimerExeServiceImpl.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java index 0d5885015..cad2e090d 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/impl/HutoolTimerExeServiceImpl.java @@ -22,10 +22,10 @@ import org.springframework.stereotype.Service; public class HutoolTimerExeServiceImpl implements TimerExeService { private static final Log log = Log.get(); - @Value("${runTake.maxRetryCount}") - private Integer maxRetryCount; - @Value("${runTake.delayTime}") - private Integer delayTime; +// @Value("${runTake.maxRetryCount}") +// private Integer maxRetryCount; +// @Value("${runTake.delayTime}") +// private Integer delayTime; @Override public void startTimer(String taskId, String cron, String className) { @@ -63,7 +63,7 @@ public class HutoolTimerExeServiceImpl implements TimerExeService { public void runTaskWithRetryAndDelay(TimerTaskRunner timerTaskRunner) throws InterruptedException { int retryCount = 0; // 重试次数计数器 - while (retryCount < maxRetryCount) { + while (retryCount < 10) { try { System.out.println("重试机制:"+(retryCount+1)); timerTaskRunner.action(); @@ -71,10 +71,10 @@ public class HutoolTimerExeServiceImpl implements TimerExeService { } catch (Exception e) { // 处理异常 retryCount++; // 增加重试次数 - Thread.sleep(delayTime); // 等待一段时间 + Thread.sleep(25000); // 等待一段时间 } } - if (retryCount >= maxRetryCount) { + if (retryCount >= 10) { // 达到最大重试次数,终止任务 return; }