如何在Java中使用ScheduledExecutorService调度任务-java教程-PHP中文网

如何在Java中使用ScheduledExecutorService调度任务

P粉602998670

发布： 2025-10-14 10:42:02

原创

198人浏览过

ScheduledExecutorService提供线程安全的定时任务调度，支持一次性延迟、固定延迟和固定频率执行，通过Executors创建实例，使用schedule、scheduleWithFixedDelay、scheduleAtFixedRate方法调度任务，返回ScheduledFuture可取消任务，需调用shutdown正确关闭以避免资源泄漏。

如何在java中使用scheduledexecutorservice调度任务

在Java中，ScheduledExecutorService 是并发包 java.util.concurrent 提供的一个接口，用于调度任务在未来某个时间点执行，或按固定频率重复执行。相比传统的 Timer 类，它更灵活、线程更安全，也支持多线程执行。

创建 ScheduledExecutorService 实例

通过 Executors 工具类可以快速创建调度服务：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);

登录后复制

这里创建了一个包含两个线程的调度线程池。你可以根据需要调整线程数，如果是单线程，可使用 newSingleThreadScheduledExecutor()。

调度一次性延迟任务

使用 schedule(Runnable command, long delay, TimeUnit unit) 方法，可以让任务在指定延迟后执行一次。

立即学习“Java免费学习笔记（深入）”；

scheduler.schedule(() -> {
    System.out.println("任务在3秒后执行");
}, 3, TimeUnit.SECONDS);

登录后复制

这段代码会在3秒后打印消息，任务只会执行一次。

调度周期性任务

有两种方式执行周期任务：固定延迟和固定频率。

1. 固定延迟执行（使用 scheduleWithFixedDelay）

任务执行结束后，再等待指定延迟时间启动下一次。

百度文心百中

百度大模型语义搜索体验中心

查看详情

scheduler.scheduleWithFixedDelay(() -> {
    System.out.println("每5秒执行一次，从上一次结束开始计时");
}, 0, 5, TimeUnit.SECONDS);

登录后复制

适用于任务执行时间不确定，希望避免重叠的情况。

2. 固定频率执行（使用 scheduleAtFixedRate）

无论任务是否完成，都按固定周期发起下一次执行（若任务耗时超过周期，则下一次会立即开始）。

scheduler.scheduleAtFixedRate(() -> {
    System.out.println("每2秒发起一次执行");
}, 0, 2, TimeUnit.SECONDS);

登录后复制

适合定时采集、心跳等场景。

取消调度任务

调用 schedule 方法会返回一个 ScheduledFuture<?> 对象，可用于取消任务。

ScheduledFuture<?> future = scheduler.schedule(() -> {
    System.out.println("这个任务可能被取消");
}, 10, TimeUnit.SECONDS);

// 在任务执行前取消
boolean canceled = future.cancel(false); // 参数 false 表示不中断正在运行的任务

登录后复制

正确关闭调度器

程序退出前应关闭调度器，避免资源泄漏。

scheduler.shutdown();
try {
    if (!scheduler.aw<a style="color:#f60; text-decoration:underline;" title="ai" href="https://www.php.cn/zt/17539.html" target="_blank">ai</a>tTermination(60, TimeUnit.SECONDS)) {
        scheduler.shutdownNow(); // 强制关闭
    }
} catch (InterruptedException e) {
    scheduler.shutdownNow();
    Thread.currentThread().interrupt();
}

登录后复制

这能确保已提交的任务有机会完成，同时防止JVM无法退出。

基本上就这些。掌握这几个核心方法，就能在项目中合理使用定时任务了。注意不要在任务中抛出未捕获异常，否则可能导致后续调度失效。建议在 Runnable 中自行捕获异常。

以上就是如何在Java中使用ScheduledExecutorService调度任务的详细内容，更多请关注php中文网其它相关文章！