ScheduledThreadPoolExecutor是Java中用于定时和周期性任务的健壮线程池，支持延迟执行、固定频率（scheduleAtFixedRate）和固定延迟（scheduleWithFixedDelay）调度，需显式关闭、避免阻塞、合理配置线程数。
ScheduledThreadPoolExecutor 是 Java 并发包中专门用于定时和周期性任务调度的线程池，它继承自 ThreadPoolExecutor，同时实现了 ScheduledExecutorService 接口。相比 Timer，它更健壮、支持多线程、能正确处理异常任务，是生产环境推荐的定时任务方案。
核心方法：如何提交定时/周期任务
主要通过以下四个方法调度任务：
-
schedule(Runnable command, long delay, TimeUnit unit)：延迟执行一次 -
schedule(Callable<V> callable, long delay, TimeUnit unit)：延迟执行一次，可返回结果 -
scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：固定频率执行（从首次执行开始计时，每 period 执行一次） -
scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：固定延迟执行（上一次执行完成后，再等 delay 时间才执行下一次）
⚠️ 注意：scheduleAtFixedRate 和 scheduleWithFixedDelay 的行为差异很关键。例如任务本身耗时 2 秒，设置 period=1 秒，前者会“追赶”执行（可能连续触发），后者则严格保证两次执行之间有 1 秒空闲。
基础用法示例：创建并使用 ScheduledThreadPoolExecutor
推荐使用 Executors.newScheduledThreadPool(n) 创建，但注意该工厂方法返回的是 ScheduledThreadPoolExecutor 实例，可安全向下转型（如需调用其特有方法）：
立即学习“Java免费学习笔记（深入）”；
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
// 延迟 3 秒后执行
scheduler.schedule(() -> System.out.println("Hello after 3s"), 3, TimeUnit.SECONDS);
// 每 5 秒执行一次，首次延迟 2 秒（固定频率）
scheduler.scheduleAtFixedRate(
() -> System.out.println("Tick at " + System.currentTimeMillis()),
2, 5, TimeUnit.SECONDS
);
// 任务执行完后，隔 3 秒再执行下一次（固定延迟）
scheduler.scheduleWithFixedDelay(
() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) { }
System.out.println("Done with delay");
},
0, 3, TimeUnit.SECONDS
);
</font>
<H3>重要注意事项与最佳实践</H3>
<ul>
<li><strong>务必显式关闭线程池</strong>：调用 <code>shutdown()</code> 或 <code>shutdownNow()</code>，否则 JVM 不会退出（后台线程持续运行）</li>
<li><strong>异常不会中断调度</strong>：单个任务抛出未捕获异常，只会终止该次执行，后续调度不受影响。如需感知失败，建议在 <code>Runnable</code> 内 try-catch 并记录日志</li>
<li><strong>慎用大核心数</strong>：定时任务通常 I/O 或轻计算为主，2–4 个线程足够；过多线程反而增加调度开销</li>
<li><strong>避免长期阻塞任务</strong>：若任务内含 <code>while(true)</code> 或长时间 sleep，会占用线程导致其他定时任务延迟。应确保任务快速返回</li>
<li><strong>取消任务用 Future</strong>：<code>schedule</code> 方法返回 <code>ScheduledFuture</code>，可调用 <code>cancel(true)</code> 尝试中断正在运行的任务</li>
</ul>
<H3>进阶：自定义拒绝策略与监控</H3>
<p><code>ScheduledThreadPoolExecutor</code> 支持传入自定义 <code>ThreadFactory</code> 和 <code>RejectedExecutionHandler</code>（虽然定时任务极少被拒绝，但在 shutdown 后提交任务会触发）：</p>
<font color="gray">
<pre class="brush:php;toolbar:false;">
ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
2,
r -> {
Thread t = new Thread(r, "my-scheduler-" + counter.incrementAndGet());
t.setDaemon(true); // 推荐设为守护线程
return t;
}
);
executor.setRejectedExecutionHandler((r, e) ->
System.err.println("Task rejected: " + r)
);
还可通过 getActiveCount()、getCompletedTaskCount() 等方法做简单运行时监控。
