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 可以方便地管理定時任務，它是處理定時任務的強大工具，特別是在需要精確控制任務執行時間的場景中。