ExecutorService如何實現任務調度

ExecutorService 是 Java 并發包 java.util.concurrent 中的一個接口，它提供了一種將任務提交給線程池執行的方式。雖然 ExecutorService 本身并不直接提供任務調度的功能，但是你可以通過組合使用 ScheduledExecutorService（它是 ExecutorService 的子接口）來實現任務的定時調度。

以下是使用 ScheduledExecutorService 實現任務調度的基本步驟：

1. 創建一個 ScheduledExecutorService 實例。通常，你可以使用 Executors 工廠方法來創建一個具有固定線程數的調度執行器：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(4);

這里創建了一個具有 4 個線程的調度執行器。 2. 定義要執行的任務。這個任務需要實現 Runnable 接口：

Runnable task = new Runnable() {
    @Override
    public void run() {
        // 在這里編寫要執行的任務代碼
        System.out.println("任務執行時間：" + LocalDateTime.now());
    }
};

3. 使用 schedule、scheduleAtFixedRate 或 scheduleWithFixedDelay 方法來安排任務的執行。

   • schedule(Runnable command, long delay, TimeUnit unit)：在給定的延遲后執行一次任務。
   • scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)：在初始延遲后開始執行任務，并按照固定的頻率重復執行。
   • scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)：在初始延遲后開始執行任務，并在每次任務完成后等待固定的延遲再執行下一次任務。

例如，如果你想在 5 秒后執行一次任務，可以使用以下代碼：

scheduler.schedule(task, 5, TimeUnit.SECONDS);

如果你想每隔 10 秒執行一次任務，可以使用以下代碼：

scheduler.scheduleAtFixedRate(task, 0, 10, TimeUnit.SECONDS);

注意：在使用完 ScheduledExecutorService 后，記得調用 shutdown() 方法來關閉它，以釋放資源。

scheduler.shutdown();

以上就是使用 ScheduledExecutorService 實現任務調度的基本步驟。你可以根據需要調整任務的執行頻率和延遲時間。