ScheduledThreadPoolExecutor是Java中用于定时或周期性任务的线程池,继承自ThreadPoolExecutor并实现ScheduledExecutorService接口,相比Timer更灵活稳定。1. 可通过Executors.newScheduledThreadPool创建实例,建议根据负载设置线程数;2. 核心方法包括schedule(延迟执行一次)、scheduleAtFixedRate(固定频率执行)和scheduleWithFixedDelay(固定延迟执行);3. 使用时需捕获任务异常、避免任务执行时间超过周期间隔导致连续运行,并在程序结束前调用shutdown关闭线程池;4. 可通过getQueue().size()监控任务积压。掌握这些方法与注意事项可可靠实现定时功能。

ScheduledThreadPoolExecutor 是 Java 中用于执行定时或周期性任务的线程池工具,它继承自 ThreadPoolExecutor 并实现了 ScheduledExecutorService 接口。相比传统的 Timer 和 TimerTask,ScheduledThreadPoolExecutor 更加灵活、稳定,支持多个线程并发执行定时任务。
创建 ScheduledThreadPoolExecutor
通过 Executors 工具类可以快速创建实例,也可以手动构造以更精细地控制参数:
示例代码:
// 创建一个大小为2的调度线程池
ScheduledThreadPoolExecutor scheduler =
(ScheduledThreadPoolExecutor) Executors.newScheduledThreadPool(2);
建议在实际项目中根据任务负载合理设置线程数,避免资源浪费或调度延迟。
核心方法介绍
ScheduledThreadPoolExecutor 提供了几个关键方法来安排任务执行:
自定义设置的程度更高可以满足大部分中小型企业的建站需求,同时修正了上一版中发现的BUG,优化了核心的代码占用的服务器资源更少,执行速度比上一版更快 主要的特色功能如下: 1)特色的菜单设置功能,菜单设置分为顶部菜单和底部菜单,每一项都可以进行更名、选择是否隐 藏,排序等。 2)增加企业基本信息设置功能,输入的企业信息可以在网页底部的醒目位置看到。 3)增加了在线编辑功能,输入产品信息,企业介绍等栏
立即学习“Java免费学习笔记(深入)”;
- schedule(Runnable command, long delay, TimeUnit unit):延迟指定时间后执行一次任务。
- scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit):在初始延迟后以固定频率重复执行,适用于“每 N 秒执行一次”的场景。
- scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit):前一次任务结束后,等待固定延迟再执行下一次,适合任务耗时不稳定的场景。
// 延迟2秒后执行
scheduler.schedule(() -> System.out.println("一次性任务执行"), 2, TimeUnit.SECONDS);
// 每隔3秒执行一次(从开始算起)
scheduler.scheduleAtFixedRate(() -> {
System.out.println("周期任务开始: " + System.currentTimeMillis());
try { Thread.sleep(1000); } catch (InterruptedException e) {}
}, 0, 3, TimeUnit.SECONDS);
// 每次任务完成后等待2秒再执行下一次
scheduler.scheduleWithFixedDelay(() -> {
System.out.println("带间隔的任务完成: " + System.currentTimeMillis());
}, 1, 2, TimeUnit.SECONDS);
注意事项与最佳实践
使用 ScheduledThreadPoolExecutor 时需注意以下几点:
- 如果任务抛出异常而未被捕获,该任务将停止后续调度。务必在 Runnable 内部做好异常捕获。
- scheduleAtFixedRate 中若任务执行时间超过周期间隔,下一次执行会立即开始(不会并发),可能导致连续运行。
- 程序结束前应调用 shutdown() 方法关闭线程池,防止内存泄漏或进程无法退出。
- 可通过 getQueue().size() 监控待执行任务数量,辅助排查调度积压问题。
基本上就这些。掌握这几个方法和细节,就能在项目中可靠地实现定时功能了。









