Java并发编程中ScheduledExecutorService使用-java教程-PHP中文网

Java并发编程中ScheduledExecutorService使用

P粉602998670

发布： 2025-09-27 14:04:02

原创

233人浏览过

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)：前一个任务完成后，等待固定延迟再执行下一个任务。

示例代码：

立即进入“豆包AI人工智官网入口”；

立即学习“豆包AI人工智能在线问答入口”；

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 则是等前一个任务结束之后，再等指定延迟才开始下一个。适合任务执行时间不确定且不希望并发的情况。

举例说明：

豆包AI编程

豆包推出的AI编程助手

483

查看详情

// 固定频率：每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() 尝试停止所有正在执行的任务。