ScheduledFuture是ScheduledExecutorService提交定时任务后返回的对象,用于控制延迟或周期性任务的执行、取消和结果获取。通过Executors.newScheduledThreadPool创建线程池后,调用schedule、scheduleAtFixedRate或scheduleWithFixedDelay提交任务,获得ScheduledFuture实例,可实现延迟执行、周期运行、取消任务、查询状态及获取返回值等功能,结合Callable还可处理有结果的任务,最终需调用shutdown释放资源。

在Java中,ScheduledFuture 是 ScheduledExecutorService 提交定时任务后返回的对象,用于管理和控制延迟或周期性执行的任务。它结合了 Future 和调度功能,既能获取任务结果,也能取消任务或查询执行状态。
创建 ScheduledExecutorService
使用 Executors.newScheduledThreadPool 创建线程池,这是操作 ScheduledFuture 的前提。
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
这里创建了一个最多两个线程的调度线程池,适合并发执行多个定时任务。
提交任务并获取 ScheduledFuture
通过 schedule 方法提交任务,返回 ScheduledFuture 实例。
立即学习“Java免费学习笔记(深入)”;
- 延迟执行:任务在指定延迟后运行一次
- 周期执行:使用 scheduleAtFixedRate 或 scheduleWithFixedDelay
// 延迟5秒后执行
ScheduledFuture<?> future = scheduler.schedule(() -> {
System.out.println("任务执行时间: " + new Date());
}, 5, TimeUnit.SECONDS);
// 每隔10秒执行一次,从第一次开始计算周期
ScheduledFuture<?> periodicFuture = scheduler.scheduleAtFixedRate(
() -> System.out.println("周期任务执行"),
0, 10, TimeUnit.SECONDS
);
使用 ScheduledFuture 控制任务
ScheduledFuture 提供了任务生命周期管理能力:
- 取消任务:调用 cancel(true) 可中断正在运行的任务
- 检查是否已取消:isCancelled()
- 检查是否已完成:isDone()
- 获取结果(如有返回值):get() 方法阻塞等待结果
// 3秒后取消任务(适用于未完成的延迟任务)
scheduler.schedule(() -> {
if (!future.isCancelled()) {
future.cancel(true);
System.out.println("任务已被取消");
}
}, 3, TimeUnit.SECONDS);
注意:如果任务已在运行,cancel(true) 会尝试中断对应线程。
处理有返回值的定时任务
若任务实现 Callable,可通过 ScheduledFuture 获取返回值。
ScheduledFuture<String> resultFuture = scheduler.schedule(() -> {
return "处理完成";
}, 2, TimeUnit.SECONDS);
// 获取结果(会阻塞直到任务完成)
try {
String result = resultFuture.get();
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
适用于需要确认任务执行结果或传递数据的场景。
基本上就这些。合理使用 ScheduledFuture 能有效控制定时任务的执行与生命周期,避免资源浪费或重复运行。记得在不再需要调度器时调用 shutdown() 释放资源。










