scheduleAtFixedRate以固定周期从上一次任务开始时间起重复执行,若任务超时则立即执行下一次(追赶式),不并发;需用Executors创建并显式关闭。

ScheduleAtFixedRate 是 Java 中 ScheduledExecutorService 提供的核心方法之一,用于以**固定频率**(即从上一次任务开始执行的时间点起,每隔指定周期再次启动)重复执行任务。它和 scheduleWithFixedDelay 容易混淆,关键区别在于:前者关注“启动时刻的间隔”,后者关注“执行完成后的延迟”。
核心用法:基本语法与参数含义
调用方式如下:
scheduler.scheduleAtFixedRate(runnable, initialDelay, period, unit);
四个参数说明:
-
runnable:要周期执行的
Runnable任务(不能抛受检异常,建议内部 try-catch) - initialDelay:首次执行前的延迟时间(可为 0)
- period:两次任务**开始时间之间**的固定间隔(不是执行完到下一次开始)
-
unit:时间单位(如
TimeUnit.SECONDS)
重要行为:任务执行超时或阻塞时会发生什么?
如果某次任务执行时间 > period,scheduleAtFixedRate 不会并发执行下一次——它会等当前任务结束,立刻开始下一次(跳过错过的调度点)。也就是说,实际执行间隔可能变短,但不会堆积线程或并行运行同一任务。
立即学习“Java免费学习笔记(深入)”;
例如:period = 2秒,但某次任务耗时 5 秒,则下一次会在第 5 秒末立即启动,而不是等到第 6 秒(即“追赶式”执行,但不并行)。
⚠️ 注意:若任务频繁超时,可能导致调度越来越密集,甚至出现“雪崩”。务必确保任务逻辑轻量,或加超时控制。
如何正确创建和关闭调度器?
推荐使用 Executors.newScheduledThreadPool(n) 创建,而非直接 new(便于复用和管理):
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
scheduler.scheduleAtFixedRate(() -> {
System.out.println("执行中:" + System.currentTimeMillis());
}, 1, 3, TimeUnit.SECONDS);
使用完毕后必须显式关闭,否则线程池不释放,JVM 无法退出:
-
shutdown():停止接收新任务,等待已提交任务完成 -
shutdownNow():尝试中断所有正在执行的任务,返回未执行的任务列表 - 建议配合
awaitTermination()等待优雅终止
替代方案对比:什么时候该用 scheduleWithFixedDelay?
如果你希望“每次执行完之后,再等固定时间才启动下一次”,就该选 scheduleWithFixedDelay。它更适用于:任务耗时不稳定、需严格避免重叠、或依赖上一次结果的场景。
举例:每 5 秒检查一次文件是否更新,且每次检查必须完整结束才能算数——这时用 fixedDelay 更安全;而每秒采集一次传感器数据(不管上次是否完成),则 fixedRate 更符合“固定频率”本意。


















