Java并发编程中ScheduledExecutorService使用

P粉602998670

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

281人浏览过

来源于php中文网

原创

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

示例代码：

立即学习“Java免费学习笔记（深入）”；

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

举例说明：

玻璃钢企业网站源码1.5

本程序源码为asp与acc编写，并没有花哨的界面与繁琐的功能，维护简单方便，只要你有一些点点asp的基础，二次开发易如反掌。 1.功能包括产品，新闻，留言簿，招聘，下载，...是大部分中小型的企业建站的首选。本程序是免费开源，只为大家学习之用。如果用于商业，版权问题概不负责。1.采用asp+access更加适合中小企业的网站模式。 2.网站页面div+css兼容目前所有主流浏览器，ie6+，Ch

下载

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