scheduledthreadpoolexecutor是java中用于定时和周期性任务的健壮线程池，支持延迟执行、固定频率（scheduleatfixedrate）和固定延迟（schedulewithfixeddelay）调度，需显式关闭、避免阻塞、合理配置线程数。
ScheduledThreadPoolExecutor 是 Java 并发包中专门用于定时和周期性任务调度的线程池，它继承自 ThreadPoolExecutor，同时实现了 ScheduledExecutorService 接口。相比 Timer，它更健壮、支持多线程、能正确处理异常任务，是生产环境推荐的定时任务方案。
核心方法：如何提交定时/周期任务
主要通过以下四个方法调度任务：
-
schedule(Runnable command, long delay, TimeUnit unit)：延迟执行一次 -
schedule(Callable<v> callable, long delay, TimeUnit unit)</v>：延迟执行一次，可返回结果 -
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 秒空闲。
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
基础用法示例：创建并使用 ScheduledThreadPoolExecutor
推荐使用 Executors.newScheduledThreadPool(n) 创建，但注意该工厂方法返回的是 ScheduledThreadPoolExecutor 实例，可安全向下转型（如需调用其特有方法）：
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
);
重要注意事项与最佳实践
-
务必显式关闭线程池：调用
shutdown()或shutdownNow()，否则 JVM 不会退出（后台线程持续运行） -
异常不会中断调度：单个任务抛出未捕获异常，只会终止该次执行，后续调度不受影响。如需感知失败，建议在
Runnable内 try-catch 并记录日志 - 慎用大核心数：定时任务通常 I/O 或轻计算为主，2–4 个线程足够；过多线程反而增加调度开销
-
避免长期阻塞任务：若任务内含
while(true)或长时间 sleep，会占用线程导致其他定时任务延迟。应确保任务快速返回 -
取消任务用 Future：
schedule方法返回ScheduledFuture，可调用cancel(true)尝试中断正在运行的任务
进阶：自定义拒绝策略与监控
ScheduledThreadPoolExecutor 支持传入自定义 ThreadFactory 和 RejectedExecutionHandler（虽然定时任务极少被拒绝，但在 shutdown 后提交任务会触发）：
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() 等方法做简单运行时监控。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
