在多线程编程中，线程池是一个非常重要的概念。线程池可以帮助我们提高程序的并发性能，并且可以有效地管理线程的生命周期。在Java中，线程池的实现是通过ThreadPoolExecutor类来完成的。
然而，在多线程编程中，线程池的资源是有限的。当线程池中的线程都被使用时，如果有新的任务提交到线程池，线程池需要决定如何处理这些新的任务，这就涉及到线程池的拒绝策略。
拒绝策略
线程池的拒绝策略决定了当线程池无法处理新的任务时，应该采取何种方式进行处理。Java中提供了四种内置的拒绝策略：
- AbortPolicy（默认）：直接抛出RejectedExecutionException异常，拒绝新的任务的提交。
- CallerRunsPolicy：将任务退回给提交任务的线程来执行，也就是任务提交者自己来执行该任务。
- DiscardOldestPolicy：丢弃线程池中最旧的任务，并尝试接收新的任务。
- DiscardPolicy：直接丢弃新的任务，不做任何处理。
自定义拒绝策略
除了以上四种内置的拒绝策略，Java还允许我们自定义拒绝策略。自定义拒绝策略需要实现RejectedExecutionHandler接口，并实现其唯一的方法rejectedExecution(Runnable r, ThreadPoolExecutor executor)。
以下是一个自定义拒绝策略的示例代码：
public class CustomRejectPolicy implements RejectedExecutionHandler {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
if (!executor.isShutdown()) {
try {
executor.getQueue().put(r);
} catch (InterruptedException e) {
// 重新中断当前线程
Thread.currentThread().interrupt();
}
}
}
}
在上述示例代码中，自定义的拒绝策略将被拒绝的任务重新放回到线程池的任务队列中，直到线程池中的线程有空闲能力继续执行这些任务。
要使用自定义的拒绝策略，只需要将其传递给ThreadPoolExecutor的构造函数即可：
ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
blockingQueue, new CustomRejectPolicy());
总结
线程池的拒绝策略决定了当线程池无法处理新的任务时的处理方式。Java提供了四种内置的拒绝策略，分别是AbortPolicy、CallerRunsPolicy、DiscardOldestPolicy和DiscardPolicy。
此外，我们还可以通过实现RejectedExecutionHandler接口来定义自己的拒绝策略。自定义拒绝策略可以根据需求来灵活地处理被拒绝的任务。
正确地选择拒绝策略对于保证系统的性能和稳定性非常重要，开发者应根据具体场景和需求来选择合适的拒绝策略。
本文来自极简博客，作者：北极星光，转载请注明原文链接：深入理解Java中的线程池拒绝策略与自定义拒绝策略
