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。