使用ScheduledExecutorService可实现任务延时或周期执行，并复用线程池资源。通过newScheduledThreadPool创建，支持schedule、scheduleAtFixedRate和scheduleWithFixedDelay三种调度方式。需调用shutdown()关闭线程池，配合awaitTermination确保优雅停机，紧急时用shutdownNow()。自定义ThreadFactory可提升线程名可读性便于调试。任务内需捕获异常防止调度终止，避免长任务影响调度精度，耗时操作应提交至独立线程池处理。
在Java中结合任务调度与线程池，主要是利用ScheduledExecutorService接口，它是ExecutorService的扩展，既能调度任务延时执行或周期性执行，又能复用线程池资源，避免频繁创建和销毁线程。
使用ScheduledExecutorService进行任务调度
ScheduledExecutorService 是 java.util.concurrent 包提供的标准接口，可以通过 Executors.newScheduledThreadPool(corePoolSize) 创建。它支持以下几种调度方式：
- schedule(Runnable command, long delay, TimeUnit unit)：延迟一定时间后执行任务
- scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：以固定频率周期执行，不管上一次是否完成
- scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：上一次执行完成后，再等指定延迟继续执行
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(3);
scheduler.schedule(() -> {
System.out.println("延迟3秒执行的任务");
}, 3, TimeUnit.SECONDS);
scheduler.scheduleAtFixedRate(() -> {
System.out.println("每2秒执行一次，从现在开始延迟1秒启动");
}, 1, 2, TimeUnit.SECONDS);
控制调度任务的生命周期
调度任务通常长期运行，因此要记得在适当时候关闭线程池，防止资源泄漏。
- 调用 shutdown() 启动正常关闭流程，不再接受新任务，等待已提交任务完成
- 配合 awaitTermination() 等待关闭完成
- 紧急情况可使用 shutdownNow() 尝试中断正在执行的任务
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
System.out.println("正在关闭调度器...");
scheduler.shutdown();
try {
if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
scheduler.shutdownNow();
}
} catch (InterruptedException e) {
scheduler.shutdownNow();
Thread.currentThread().interrupt();
}
}));
自定义线程工厂提升可观测性
默认线程池创建的线程名称不明确，不利于调试。可通过自定义 ThreadFactory 设置有意义的线程名。
立即学习“Java免费学习笔记（深入）”；
ThreadFactory namedFactory = r -> {
Thread t = new Thread(r, "scheduled-task-thread-" + counter.incrementAndGet());
t.setDaemon(false); // 可根据需要设置守护线程
return t;
};
ScheduledExecutorService scheduler =
new ScheduledThreadPoolExecutor(2, namedFactory);
处理异常和长任务影响调度
调度任务中的异常若未捕获，会导致该任务后续不再执行（尤其是周期任务）。建议在 Runnable 内部做好 try-catch。
scheduler.scheduleAtFixedRate(() -> {
try {
riskyOperation();
} catch (Exception e) {
System.err.println("任务执行出错：" + e.getMessage());
}
}, 1, 5, TimeUnit.SECONDS);
同时注意：长时间运行的任务会影响周期调度的准确性，必要时应将耗时操作异步提交到另一个普通线程池处理。
基本上就这些。合理使用 ScheduledExecutorService，既能实现精准调度，又能高效利用线程资源。
