如何解决Java ExecutorService的线程池拒绝策略问题

在Java中，当ExecutorService无法处理新提交的任务时，会抛出RejectedExecutionException异常。为了解决这个问题，可以根据具体需求选择合适的拒绝策略。以下是四种内置的拒绝策略：

1. AbortPolicy（默认策略）：直接抛出RejectedExecutionException异常，不进行任何处理。
2. CallerRunsPolicy：直接在调用者线程中运行被拒绝的任务。
3. DiscardPolicy：直接丢弃被拒绝的任务，不进行任何处理。
4. DiscardOldestPolicy：丢弃队列中最旧的任务，然后尝试重新提交被拒绝的任务。

要使用这些策略，需要创建一个ThreadPoolExecutor实例，并在其构造函数中传入一个RejectedExecutionHandler实例。以下是一个示例：

import java.util.concurrent.*;

public class RejectedExecutionHandlerExample {
    public static void main(String[] args) {
        int corePoolSize = 2;
        int maximumPoolSize = 4;
        long keepAliveTime = 10;
        TimeUnit unit = TimeUnit.SECONDS;
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(10);

        // 创建一个拒绝策略
        RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.CallerRunsPolicy();

        // 创建一个线程池
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                unit,
                workQueue,
                Executors.defaultThreadFactory(),
                rejectedExecutionHandler
        );

        // 提交任务
        for (int i = 0; i < 10; i++) {
            int finalI = i;
            threadPoolExecutor.submit(() -> {
                System.out.println("Task " + finalI + " is running on thread " + Thread.currentThread().getName());
            });
        }

        // 关闭线程池
        threadPoolExecutor.shutdown();
    }
}

在这个示例中，我们创建了一个包含2个核心线程和最大4个线程的线程池。当提交第11个任务时，因为队列已满，所以新任务会被拒绝。我们使用了CallerRunsPolicy策略，直接在调用者线程中运行被拒绝的任务。这样可以让调用者线程等待任务执行完成，从而避免程序崩溃。