From f93d4f2820cb1b07c896a61dabb50918a52f74c9 Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Sun, 29 Mar 2026 17:11:31 +0800 Subject: [PATCH] =?UTF-8?q?fix(scheduler):=20=E4=BF=AE=E5=A4=8D=E5=AE=9A?= =?UTF-8?q?=E6=97=B6=E4=BB=BB=E5=8A=A1=E5=9B=BA=E5=AE=9A=E9=A2=91=E7=8E=87?= =?UTF-8?q?=E8=B0=83=E5=BA=A6=E6=97=B6=E9=97=B4=E8=AE=A1=E7=AE=97=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在固定频率调度中清除毫秒精度并增加一秒延迟 - 修正了从指定时间开始的触发间隔计算逻辑 - 避免了时间计算中的毫秒误差累积问题 --- .../admin/scheduler/type/strategy/FixRateScheduleType.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/type/strategy/FixRateScheduleType.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/type/strategy/FixRateScheduleType.java index b71dda70..c94001ae 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/type/strategy/FixRateScheduleType.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/scheduler/type/strategy/FixRateScheduleType.java @@ -2,6 +2,7 @@ package com.xxl.job.admin.scheduler.type.strategy; import com.xxl.job.admin.model.XxlJobInfo; import com.xxl.job.admin.scheduler.type.ScheduleType; +import com.xxl.tool.core.DateTool; import java.util.Date; @@ -15,7 +16,8 @@ public class FixRateScheduleType extends ScheduleType { // fix rate delay, after last-trigger-time return nextTriggerTime; } else { - // fix rate delay, after fromTime + // fix rate delay, after fromTime (clear ms, second +1) + fromTime = DateTool.setMilliseconds(DateTool.addSeconds(fromTime, 1), 0); return new Date(fromTime.getTime() + Long.parseLong(jobInfo.getScheduleConf()) * 1000L); } }