ScheduledThreadPoolExecutor 是基于 DelayedWorkQueue 最小堆实现的定时调度线程池，支持 schedule、scheduleAtFixedRate 和 scheduleWithFixedDelay 三种调度方式，单线程默认配置保障顺序性与稳定性。
ScheduledThreadPoolExecutor 是 Java 并发包中专门用于执行定时和周期性任务的线程池，它继承自 ThreadPoolExecutor，并实现了 ScheduledExecutorService 接口。它的调度核心依赖于一个**基于堆的优先队列（DelayedWorkQueue）**，按任务的下次执行时间排序，配合工作线程“等待-唤醒”机制实现精准调度。
调度原理：延迟队列 + 线程轮询
每次提交定时任务（如 schedule()、scheduleAtFixedRate()），任务会被封装为 ScheduledFutureTask，并插入内部的 DelayedWorkQueue。这个队列不是 FIFO，而是按任务的 time 字段（纳秒级绝对时间戳）构建的最小堆——队首始终是**最早该执行的任务**。
工作线程在执行完一个任务后，会调用 delayedQueue.poll() 或 take() 获取下一个任务：
- 若队首任务还没到执行时间，线程会阻塞在
take()上，直到超时或被唤醒； - 若已到时间，立即取出执行；
- 周期性任务执行后，会重新计算下一次触发时间，再次入队。
常用调度方法及行为差异
注意不同方法对“延迟”和“间隔”的理解不同，直接影响调度节奏：
立即学习“Java免费学习笔记（深入）”；
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
-
schedule(Runnable, delay, TimeUnit)：只执行一次，delay 后触发； -
scheduleAtFixedRate(Runnable, initialDelay, period, TimeUnit)：以固定频率执行，从 initialDelay 开始，**不管前一次是否执行完**，到点就触发（可能并发）； -
scheduleWithFixedDelay(Runnable, initialDelay, delay, TimeUnit)：每次执行完后，再等 delay 时间才开始下一次，**严格串行，无重叠**。
例如：任务耗时 800ms，设 fixedRate(1s)，第 2 次会在第 1s 准时启动（与第 1 次并发）；而 fixedDelay(1s) 则在第 1.8s 启动（1s + 0.8s）。
线程数设置与调度稳定性
默认构造函数创建的是单线程池（corePoolSize = 1），适合大多数定时场景——避免多线程竞争调度队列，也防止任务堆积时互相干扰。
若需并发执行多个定时任务（比如多个独立报表生成），可指定更大的 corePoolSize：
- 但要注意：每个线程独立从队列取任务，仍遵循“最早到期优先”，不会破坏调度顺序；
- 线程数过多反而可能因上下文切换和锁竞争降低响应精度；
- 建议不超过 CPU 核心数 × 2，且确保任务本身是 CPU 轻量或 I/O 异步的。
异常处理与任务失败影响
任务内未捕获的异常会导致当前任务终止，但不影响线程存活和其他任务调度——这是 ScheduledThreadPoolExecutor 的关键健壮性设计。
不过周期性任务一旦抛异常，后续执行将直接停止（不会自动重试）。因此务必在 Runnable/Callable 中自行 try-catch：
- 记录日志；
- 必要时主动重调度（如用
scheduleWithFixedDelay包裹重试逻辑）； - 避免使用
execute()提交定时任务，它不支持延迟语义。
