17370845950

ScheduledExecutorService是Java中用于执行延迟或周期性任务的接口，相比Timer更灵活稳定。通过Executors可创建单线程或固定数量线程池，如newScheduledThreadPool(2)。使用schedule()执行一次延迟任务，5秒后运行示例代码。通过scheduleWithFixedDelay()实现固定延迟周期执行，每3秒运行一次并模拟耗时操作；scheduleAtFixedRate()则按固定频率触发。调用schedule方法返回ScheduledFuture，可用于cancel(false)取消任务，并在10秒后自动取消示例任务。最后需调用shutdown()优雅关闭线程池，超时则强制shutdownNow()，防止资源泄漏。实际使用中应注意异常处理与中断响应，推荐封装任务逻辑以提升健壮性。

在Java中，ScheduledExecutorService 是并发包 java.util.concurrent 提供的一个接口，用于执行延迟任务或周期性任务。相比传统的 Timer 类，它更加灵活、稳定，并支持多线程调度，是执行定时任务的推荐方式。

创建 ScheduledExecutorService 实例

通过 Executors 工具类可以方便地创建不同类型的调度线程池：

示例：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);

执行延迟任务

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

示例：5秒后打印一条消息

scheduler.schedule(() -> {
    System.out.println("延迟任务执行时间：" + System.currentTimeMillis());
}, 5, TimeUnit.SECONDS);

执行周期性任务

有两种方式执行周期任务：

示例：每3秒以固定延迟执行一次

scheduler.scheduleWithFixedDelay(() -> {
    System.out.println("周期任务运行中..." + Thread.currentThread().getName());
    try {
        Thread.sleep(1000); // 模拟耗时操作
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}, 0, 3, TimeUnit.SECONDS);

取消定时任务

调用 schedule 方法会返回一个 ScheduledFuture> 对象，可通过其 cancel(boolean mayInterruptIfRunning) 方法取消任务。

示例：执行10秒后自动关闭调度器并取消任务

ScheduledFuture future = scheduler.scheduleWithFixedDelay(() -> {
    System.out.println("正在运行...");
}, 1, 2, TimeUnit.SECONDS);

// 10秒后取消任务
scheduler.schedule(() -> {
    future.cancel(false);
    System.out.println("任务已取消");
}, 10, TimeUnit.SECONDS);

注意：取消任务后应合理关闭线程池，避免资源泄漏。

关闭线程池

程序结束前应调用 shutdown() 方法优雅关闭调度器：

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

基本上就这些。ScheduledExecutorService 使用起来清晰高效，适合大多数需要定时或周期执行的场景，掌握好创建、调度、取消和关闭流程，就能在实际项目中灵活运用。不复杂但容易忽略细节，比如异常处理和线程中断响应，建议封装任务逻辑时加以考虑。