如何使用 ScheduledExecutorService 延遲執行任務

ScheduledExecutorService 是 Java 并發包 java.util.concurrent 中的一個接口，它允許你在給定的延遲后運行任務，或者定期執行任務

1. 導入必要的包：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

2. 創建一個 Runnable 任務：

class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("任務執行于: " + LocalDateTime.now());
    }
}

3. 創建 ScheduledExecutorService 實例：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

這里我們創建了一個具有單個線程的 ScheduledExecutorService。

4. 使用 schedule 方法延遲執行任務：

long delay = 5; // 延遲時間（單位：秒）
MyTask task = new MyTask();
scheduler.schedule(task, delay, TimeUnit.SECONDS);

這將使任務在 5 秒后執行一次。

5. 若要定期執行任務，可以使用 scheduleAtFixedRate 或 scheduleWithFixedDelay 方法：

long initialDelay = 0; // 初始延遲時間（單位：秒）
long period = 2; // 任務執行間隔（單位：秒）

// 使用 scheduleAtFixedRate 方法
scheduler.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);

// 或者使用 scheduleWithFixedDelay 方法
scheduler.scheduleWithFixedDelay(task, initialDelay, period, TimeUnit.SECONDS);

scheduleAtFixedRate 方法會在固定的速率下執行任務，而 scheduleWithFixedDelay 方法會在每次任務執行完成后等待固定的延遲時間再執行下一次任務。

6. 關閉 ScheduledExecutorService：

在不再需要執行任務時，應關閉 ScheduledExecutorService 以釋放資源：

scheduler.shutdown();

注意：調用 shutdown 方法后，已提交的任務將繼續執行，但不會接受新的任務。如果需要在關閉前等待正在執行的任務完成，可以使用 awaitTermination 方法：

scheduler.shutdown();
try {
    if (!scheduler.awaitTermination(60, TimeUnit.SECONDS)) {
        scheduler.shutdownNow();
    }
} catch (InterruptedException e) {
    scheduler.shutdownNow();
}

這將等待最多 60 秒，直到所有任務完成執行，或者超時發生。如果在超時時間內任務未完成，則會調用 shutdownNow 方法強制關閉 ScheduledExecutorService。