当前位置：首页 > 文章列表 > 文章 > java教程 > Java并发ScheduledExecutorService使用教程

Java并发ScheduledExecutorService使用教程

2026-01-29 12:18:50 0浏览收藏

“纵有疾风来，人生不言弃”，这句话送给正在学习文章的朋友们，也希望在阅读本文《Java并发ScheduledExecutorService详解》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新文章相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

ScheduledExecutorService是Java中用于定时或周期性任务调度的高效工具，支持线程池管理。通过Executors.newScheduledThreadPool创建实例，提供三种调度方法：schedule用于延迟执行一次；scheduleAtFixedRate以固定频率重复执行，基于开始时间计算间隔，可能产生任务重叠；scheduleWithFixedDelay则在前一个任务完成后等待指定延迟再执行，适用于执行时间不确定的场景。正确关闭需调用shutdown()并配合awaitTermination等待任务结束，必要时调用shutdownNow()强制停止。使用时应避免未捕获异常导致任务中断，合理设置线程池大小，并在需要持久化或分布式调度时选用Quartz等高级框架，同时记录日志便于监控。掌握其用法可有效替代传统Timer，提升并发环境下定时任务的稳定性和性能。

Java并发编程中ScheduledExecutorService使用

ScheduledExecutorService 是 Java 并发包（java.util.concurrent）中用于执行定时或周期性任务的核心工具。相比传统的 Timer 和 TimerTask，它更加灵活、健壮，支持线程池管理，能更好地应对高并发场景。

1. ScheduledExecutorService 基本用法

通过 Executors 工具类可以快速创建 ScheduledExecutorService 实例：

Executors.newScheduledThreadPool(int corePoolSize);

常用调度方法包括：

schedule(Runnable command, long delay, TimeUnit unit)：延迟指定时间后执行一次任务。
scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：在初始延迟后以固定频率重复执行，无论上一个任务是否完成。
scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：前一个任务完成后，等待固定延迟再执行下一个任务。

示例代码：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2); scheduler.schedule(() -> { System.out.println("5秒后执行一次"); }, 5, TimeUnit.SECONDS); scheduler.scheduleAtFixedRate(() -> { System.out.println("每2秒执行一次，从第1秒开始"); }, 1, 2, TimeUnit.SECONDS);

2. scheduleAtFixedRate 与 scheduleWithFixedDelay 的区别

这两个方法都用于周期性任务，但执行逻辑不同：

scheduleAtFixedRate 按“开始时间”计算间隔。比如每2秒执行一次，即使某个任务耗时3秒，下一个任务仍会在前一个开始后的第2秒尝试启动（可能重叠）。
scheduleWithFixedDelay 则是等前一个任务结束之后，再等指定延迟才开始下一个。适合任务执行时间不确定且不希望并发的情况。

举例说明：

// 固定频率：每3秒开始一次，不管上次是否结束 scheduler.scheduleAtFixedRate(task, 0, 3, TimeUnit.SECONDS); // 固定延迟：每次任务结束后等待2秒再开始下一次 scheduler.scheduleWithFixedDelay(task, 0, 2, TimeUnit.SECONDS);

3. 正确关闭 ScheduledExecutorService

如果不显式关闭，即使主线程结束，调度线程仍可能保持运行，导致程序无法退出。

推荐关闭方式：

scheduler.shutdown(); try { if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) { scheduler.shutdownNow(); } } catch (InterruptedException e) { scheduler.shutdownNow(); Thread.currentThread().interrupt(); }

shutdown() 启动有序关闭，已提交的任务会继续执行；shutdownNow() 尝试停止所有正在执行的任务。