From 4d7dcbfd52a660f9b4cbe9b58ecfadc421389362 Mon Sep 17 00:00:00 2001 From: xiaochaihu <2521303550@qq.com> Date: Sat, 12 Apr 2025 19:52:52 +0800 Subject: [PATCH] =?UTF-8?q?feat(1.5.0-beta1):=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E6=97=B6=E9=97=B4=E8=BD=AE=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/retry/task/support/timer/RetryTimerWheel.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java index 6cfd805b8..dc5b6fc94 100644 --- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java +++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java @@ -54,7 +54,7 @@ public class RetryTimerWheel { public static synchronized void register(String idempotentKey, TimerTask task, Duration delay) { register(idempotentKey, hashedWheelTimer -> { - SnailJobLog.LOCAL.debug("加入时间轮. delay:[{}ms] taskType:[{}]", delay, idempotentKey); + SnailJobLog.LOCAL.debug("加入时间轮. delay:[{}ms] taskType:[{}]", delay.toMillis(), idempotentKey); timer.newTimeout(task, Math.max(delay.toMillis(), 0), TimeUnit.MILLISECONDS); }); }