17370845950

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 实例。

• 延迟执行：任务在指定延迟后运行一次
• 周期执行：使用 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 resultFuture = scheduler.schedule(() -> {
    return "处理完成";
}, 2, TimeUnit.SECONDS);

// 获取结果（会阻塞直到任务完成）
try {
    String result = resultFuture.get();
    System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

适用于需要确认任务执行结果或传递数据的场景。

基本上就这些。合理使用 ScheduledFuture 能有效控制定时任务的执行与生命周期，避免资源浪费或重复运行。记得在不再需要调度器时调用 shutdown() 释放资源。