Java ScheduledExecutorService 用法是什么

ScheduledExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种可以调度命令在给定的延迟后运行，或者定期执行或以固定的速率执行的机制。这个接口扩展了 ExecutorService 接口，因此它也支持管理终止和生成 Future 对象来跟踪异步任务的进度。

以下是 ScheduledExecutorService 的一些基本用法：

1. 创建 ScheduledExecutorService 实例： 通常通过 Executors 工厂方法创建 ScheduledExecutorService 实例。

   ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(4);
   

2. 调度任务在给定的延迟后运行： 使用 schedule 方法可以在指定的延迟后执行一次性任务。

   scheduler.schedule(new RunnableTask(), 5, TimeUnit.SECONDS);
   

3. 调度任务定期执行： 使用 scheduleAtFixedRate 或 scheduleWithFixedDelay 方法可以定期执行任务。

   • scheduleAtFixedRate 在初始延迟后开始执行任务，并且之后按照固定的周期执行，不管任务的执行时间如何。
   • scheduleWithFixedDelay 在初始延迟后开始执行任务，并且在每次任务完成后等待固定的延迟再执行下一次任务。

   // 每隔10秒执行一次任务
   scheduler.scheduleAtFixedRate(new RunnableTask(), 0, 10, TimeUnit.SECONDS);
   
   // 每次任务完成后等待5秒再执行下一次任务
   scheduler.scheduleWithFixedDelay(new RunnableTask(), 0, 5, TimeUnit.SECONDS);
   

4. 取消调度任务： 如果需要取消已经调度的任务，可以使用 Future 对象的 cancel 方法。

   Future<?> future = scheduler.schedule(new RunnableTask(), 5, TimeUnit.SECONDS);
   future.cancel(true); // 如果任务已经开始，尝试中断它
   

5. 关闭 ScheduledExecutorService： 当不再需要调度器时，应该关闭它以释放资源。

   scheduler.shutdown(); // 不再接受新的任务，但会等待已提交的任务完成
   // 或者
   scheduler.shutdownNow(); // 尝试停止所有正在执行的任务，并返回等待执行的任务列表
   

下面是一个简单的 RunnableTask 示例，它实现了 Runnable 接口：

class RunnableTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Task executed at: " + new Date());
    }
}

使用 ScheduledExecutorService 可以方便地管理定时任务，它是处理定时任务的强大工具，特别是在需要精确控制任务执行时间的场景中。