Java定时任务教程：ScheduledThreadPoolExecutor详解

本篇文章给大家分享《Java定时任务怎么用\_ScheduledThreadPoolExecutor使用教程》，覆盖了文章的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

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) 方法可以在指定延迟后执行任务。

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 秒开始下一次。若任务执行耗时较长，后续的间隔仍从任务结束算起，不会重叠。

执行周期性任务（固定频率）

使用 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("任务已被取消");
}

及时取消不再需要的任务，防止内存泄漏和无效调度。

关闭线程池

程序退出或模块销毁时，应主动关闭线程池，释放资源。

scheduler.shutdown();
try {
    if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
        scheduler.shutdownNow(); // 强制关闭
    }
} catch (InterruptedException e) {
    scheduler.shutdownNow();
    Thread.currentThread().interrupt();
}

正常关闭流程：先调用 shutdown()，再用 awaitTermination 等待任务完成，超时则强制终止。

基本上就这些。掌握好 ScheduledThreadPoolExecutor 的几种调度方式和生命周期管理，就能高效实现各类定时任务需求。注意避免忘记关闭线程池或无限循环任务导致应用无法退出的问题。

本篇关于《Java定时任务教程：ScheduledThreadPoolExecutor详解》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！