ScheduledThreadPoolExecutor可创建多线程定时任务，支持延迟执行、固定延迟和固定频率周期任务，通过schedule、scheduleWithFixedDelay、scheduleAtFixedRate方法实现，返回ScheduledFuture用于取消任务，需调用shutdown合理关闭线程池以释放资源。
在Java中，ScheduledThreadPoolExecutor 是一个功能强大的线程池工具，用于执行延迟任务或周期性任务。它继承自 ThreadPoolExecutor，实现了 ScheduledExecutorService 接口，相比传统的 Timer 类，它支持多线程并发执行定时任务，更加灵活、稳定。
创建 ScheduledThreadPoolExecutor 实例
通过构造函数可以指定核心线程数，也可以使用 Executors 工具类快速创建：
// 方式一：直接 new ScheduledThreadPoolExecutor scheduler = new ScheduledThreadPoolExecutor(2); // 方式二：通过 Executors 工厂（底层也是 new） ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
参数 2 表示最多有 2 个核心线程来执行定时任务。根据实际业务需求设置合理的核心线程数，避免资源浪费或调度阻塞。
执行延迟任务（只执行一次）
使用 schedule(Runnable command, long delay, TimeUnit unit) 方法可以在指定延迟后执行任务。
立即学习“Java免费学习笔记（深入）”；
scheduler.schedule(() -> {
System.out.println("任务执行时间：" + System.currentTimeMillis());
}, 5, TimeUnit.SECONDS);
这段代码表示：当前任务将在 5 秒后执行一次。适合处理“延迟触发”类场景，比如延迟发送通知、延时清理缓存等。
执行周期性任务（固定延迟）
使用 scheduleWithFixedDelay 可以让任务在首次延迟后反复执行，每次执行完成后再等待指定延迟继续下一次。
scheduler.scheduleWithFixedDelay(() -> {
System.out.println("周期任务开始：" + System.currentTimeMillis());
try {
Thread.sleep(2000); // 模拟耗时操作
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
System.out.println("周期任务结束");
}, 1, 3, TimeUnit.SECONDS);
说明：首次延迟 1 秒，任务执行完毕后，再等待 3 秒开始下一次。若任务执行耗时较长，后续的间隔仍从任务结束算起，不会重叠。
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
执行周期性任务（固定频率）
使用 scheduleAtFixedRate 实现固定频率调度，无论任务是否完成，都按周期发起下一次执行（如果前一次未完成，则等待其结束）。
scheduler.scheduleAtFixedRate(() -> {
System.out.println("固定频率任务启动：" + System.currentTimeMillis());
try {
Thread.sleep(4000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}, 1, 2, TimeUnit.SECONDS);
说明：每 2 秒发起一次执行，但由于任务本身耗时 4 秒，因此实际是串行执行，不会有并发问题。适用于需要严格控制执行节奏的任务，如心跳上报。
取消定时任务
调用 schedule 系列方法会返回一个 ScheduledFuture<?> 对象，可通过它来取消任务。
ScheduledFuture<?> future = scheduler.scheduleAtFixedRate(() -> {
System.out.println("正在执行...");
}, 1, 2, TimeUnit.SECONDS);
// 在某个条件下取消任务
future.cancel(false); // 参数 false 表示不中断正在运行的任务
// 判断是否已取消
if (future.isCancelled()) {
System.out.println("任务已被取消");
}
</font>
及时取消不再需要的任务，防止内存泄漏和无效调度。
关闭线程池
程序退出或模块销毁时，应主动关闭线程池，释放资源。
scheduler.shutdown();
try {
if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
scheduler.shutdownNow(); // 强制关闭
}
} catch (InterruptedException e) {
scheduler.shutdownNow();
Thread.currentThread().interrupt();
}
正常关闭流程：先调用 shutdown()，再用 awaitTermination 等待任务完成，超时则强制终止。
基本上就这些。掌握好 ScheduledThreadPoolExecutor 的几种调度方式和生命周期管理，就能高效实现各类定时任务需求。注意避免忘记关闭线程池或无限循环任务导致应用无法退出的问题。
