如何为定时任务补偿系统休眠导致的执行时间偏差？

问题背景 #

我编写了一个简单的概念验证程序，用于调度Runnable在指定时间执行，正常场景下任务能按时运行：

public static void main(String[] args) throws InterruptedException, ExecutionException {
    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("MM/dd/yyyy hh:mm:ss a");
    ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
    Runnable task = () -> System.out.println("Task Ran @ " + formatter.format(LocalDateTime.now()));

    LocalDateTime now = LocalDateTime.now();
    LocalDateTime runTime = ciel(ChronoUnit.MINUTES, now.plusMinutes(1));

    Duration duration = Duration.between(now, runTime);
    long initialDelay = duration.toMillis();

    System.out.println("Schedule @ " + formatter.format(now));
    System.out.println("Expected @ " + formatter.format(runTime));
    scheduler.schedule(task, initialDelay, TimeUnit.MILLISECONDS);

    scheduler.shutdown();
    scheduler.awaitTermination(2, TimeUnit.MINUTES);
}

private static LocalDateTime ciel(TemporalUnit precision, LocalDateTime time) {
    return time.truncatedTo(precision).plus(1, precision);
}

正常输出：

Schedule @ 12/18/2023 11:31:47 AM
Expected @ 12/18/2023 11:33:00 AM
Task Ran @ 12/18/2023 11:33:00 AM

但如果程序运行期间系统休眠再唤醒，任务执行时间会偏离预期：

Schedule @ 12/18/2023 11:35:53 AM
Expected @ 12/18/2023 11:37:00 AM
Task Ran @ 12/18/2023 11:39:13 AM

假设系统在预定执行时间前唤醒，该如何补偿才能让任务仍按预期时间执行？

解决方案 #

核心问题在于ScheduledExecutorService依赖系统单调时钟（System.nanoTime()）计算延迟，系统休眠时该时钟会暂停，唤醒后任务的实际延迟等于休眠时长加原定延迟，导致执行滞后。要解决这个问题，需要改用真实墙上时钟判断执行时机，而非依赖固定初始延迟。

方案1：自定义动态调度逻辑，唤醒后重新计算延迟 #

放弃直接使用scheduler.schedule()的固定延迟，改用周期性检查的方式，每次调度时重新计算当前真实时间到目标执行时间的剩余延迟：

public static void main(String[] args) throws InterruptedException, ExecutionException {
    DateTimeFormatter formatter = DateTimeFormatter.ofPattern("MM/dd/yyyy hh:mm:ss a");
    ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
    Runnable task = () -> System.out.println("Task Ran @ " + formatter.format(LocalDateTime.now()));

    LocalDateTime now = LocalDateTime.now();
    LocalDateTime runTime = ciel(ChronoUnit.MINUTES, now.plusMinutes(1));

    System.out.println("Schedule @ " + formatter.format(now));
    System.out.println("Expected @ " + formatter.format(runTime));

    // 自定义调度任务，负责检查并触发目标任务
    Runnable schedulerTask = () -> {
        LocalDateTime current = LocalDateTime.now();
        if (current.isAfter(runTime) || current.isEqual(runTime)) {
            task.run();
        } else {
            // 重新计算剩余延迟，再次调度自身
            Duration remaining = Duration.between(current, runTime);
            scheduler.schedule(schedulerTask, remaining.toMillis(), TimeUnit.MILLISECONDS);
        }
    };

    // 首次调度
    Duration initialDelay = Duration.between(now, runTime);
    scheduler.schedule(schedulerTask, initialDelay.toMillis(), TimeUnit.MILLISECONDS);

    scheduler.shutdown();
    scheduler.awaitTermination(2, TimeUnit.MINUTES);
}

private static LocalDateTime ciel(TemporalUnit precision, LocalDateTime time) {
    return time.truncatedTo(precision).plus(1, precision);
}

方案2：使用成熟的墙上时钟调度框架（如Quartz） #

生产环境更推荐使用Quartz这类专业调度库，它原生支持基于真实时间的任务调度，系统休眠唤醒后会自动校正执行时间，无需手动编写补偿逻辑。

关键原理说明 #

• ScheduledExecutorService的schedule方法依赖System.nanoTime()，该时钟在系统休眠时不会前进，导致休眠时长被计入延迟，任务执行滞后。
• 自定义方案通过每次调度时重新计算真实时间与目标时间的差值，确保系统唤醒后能立刻修正延迟，只要唤醒时间早于目标执行时间，就能保证任务在预期时间触发。

内容的提问来源于stack exchange，提问作者Cardinal System