Java中ScheduledThreadPoolExecutor定时任务的核心是创建调度线程池并提交延迟或周期性任务，需手动构造以控制参数、妥善处理异常与资源释放。
Java 中用 ScheduledThreadPoolExecutor 定时执行任务，核心是创建调度线程池、提交带延迟或周期性执行的任务，同时注意资源释放和异常处理。
创建 ScheduledThreadPoolExecutor 实例
它继承自 ThreadPoolExecutor，实现了 ScheduledExecutorService 接口。推荐通过 Executors.newScheduledThreadPool(int corePoolSize) 创建，但更推荐手动构造以明确控制参数：
- 指定核心线程数（一般不设为 0，否则无法执行任务）
- 可传入自定义的
ThreadFactory方便追踪线程 - 可指定拒绝策略（默认是
AbortPolicy）
示例：
ScheduledThreadPoolExecutor scheduler = new ScheduledThreadPoolExecutor(
2,
new ThreadFactory() {
private final AtomicInteger counter = new AtomicInteger(1);
public Thread newThread(Runnable r) {
return new Thread(r, "scheduler-task-" + counter.getAndIncrement());
}
}
);
提交一次性延迟任务
使用 schedule(Runnable command, long delay, TimeUnit unit) 或带 Callable 的重载方法，在指定延迟后执行一次：
立即学习“Java免费学习笔记（深入）”；
- 任务不会自动重复，只运行一次
- 返回
ScheduledFuture<?>，可用于取消或查询状态 - 若任务抛出未捕获异常，该异常会“静默丢失”，除非显式调用
get()获取
示例：
ScheduledFuture<?> future = scheduler.schedule(() -> {
System.out.println("3秒后执行一次：" + System.currentTimeMillis());
}, 3, TimeUnit.SECONDS);
// 可随时取消（如果还没开始执行）
// future.cancel(true);
提交周期性任务
有两个关键方法：
-
scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：按固定频率执行，从初始延迟后开始，每period时间触发一次（即使前一次未完成，也可能并发执行） -
scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：每次执行完后，再等待delay时间才开始下一次，天然串行，更安全
⚠️ 注意：周期性任务一旦启动，需手动调用 shutdown() 停止，否则线程池一直存活。
关闭调度器与最佳实践
避免内存泄漏和线程残留：
- 任务完成后调用
shutdown()，再配合awaitTermination()等待结束 - 如有未完成的周期任务，建议先
shutdownNow()强制中断（会尝试中断正在运行的任务线程） - 在
finally或try-with-resources（需包装成 AutoCloseable）中关闭 - 不要在定时任务里直接抛出未捕获异常——建议用 try-catch 包裹逻辑并记录日志
示例关闭流程：
try {
// 提交任务...
} finally {
scheduler.shutdown();
try {
if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
scheduler.shutdownNow();
}
} catch (InterruptedException e) {
scheduler.shutdownNow();
Thread.currentThread().interrupt();
}
}
