java Executor執行器的飽和策略有哪些

Java Executor執行器的飽和策略主要有以下幾種：

1. AbortPolicy（默認策略）

• 行為：當任務隊列已滿時，新的任務提交會拋出RejectedExecutionException異常。
• 適用場景：適用于不允許任務丟失的場景，需要明確知道哪些任務被拒絕了。

2. CallerRunsPolicy

• 行為：當任務隊列已滿時，新的任務會在調用者線程中執行。
• 優點：可以防止任務提交過快導致系統過載，同時保證任務最終會被執行。
• 缺點：可能會影響調用者線程的性能，特別是當調用者線程本身也在執行其他重要任務時。

3. DiscardPolicy

• 行為：當任務隊列已滿時，新的任務會被直接丟棄，不會拋出異常，也不會執行。
• 適用場景：適用于對任務丟失不敏感的場景，例如日志記錄任務。

4. DiscardOldestPolicy

• 行為：當任務隊列已滿時，會丟棄隊列中最舊的任務，然后嘗試重新提交新的任務。
• 優點：可以確保最新的任務有機會被執行。
• 缺點：可能會導致一些重要但不緊急的任務被丟棄。

示例代碼

以下是如何使用這些飽和策略的示例代碼：

import java.util.concurrent.*;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 創建一個容量為2的隊列
        BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(2);

        // 使用默認的AbortPolicy
        ThreadPoolExecutor executor1 = new ThreadPoolExecutor(
                1, 1, 0L, TimeUnit.MILLISECONDS, queue,
                new ThreadPoolExecutor.AbortPolicy());

        // 使用CallerRunsPolicy
        ThreadPoolExecutor executor2 = new ThreadPoolExecutor(
                1, 1, 0L, TimeUnit.MILLISECONDS, queue,
                new ThreadPoolExecutor.CallerRunsPolicy());

        // 使用DiscardPolicy
        ThreadPoolExecutor executor3 = new ThreadPoolExecutor(
                1, 1, 0L, TimeUnit.MILLISECONDS, queue,
                new ThreadPoolExecutor.DiscardPolicy());

        // 使用DiscardOldestPolicy
        ThreadPoolExecutor executor4 = new ThreadPoolExecutor(
                1, 1, 0L, TimeUnit.MILLISECONDS, queue,
                new ThreadPoolExecutor.DiscardOldestPolicy());

        // 提交任務進行測試
        for (int i = 0; i < 5; i++) {
            final int taskNumber = i;
            try {
                executor1.submit(() -> {
                    System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                });
            } catch (RejectedExecutionException e) {
                System.out.println("Task " + taskNumber + " was rejected by AbortPolicy");
            }
        }

        // 關閉執行器
        executor1.shutdown();
        executor2.shutdown();
        executor3.shutdown();
        executor4.shutdown();
    }
}

總結

選擇合適的飽和策略取決于具體的應用場景和需求。例如，如果需要確保所有任務都能被執行，可以選擇CallerRunsPolicy；如果對任務丟失不敏感，可以選擇DiscardPolicy或DiscardOldestPolicy。