Java线程池的拒绝策略及其实现

Java线程池的拒绝策略实现详解 Java线程池的拒绝策略是指当线程池中的线程数量达到最大值时，如何处理新的任务提交的策略。这个策略是由RejectedExecutionHandler接口定义的，提供了四种默认的拒绝策略：CallerRunsPolicy、AbortPolicy、DiscardPolicy和DiscardOldestPolicy。 让我们了解一下线程池的基本概念。线程池是池化思想的产物，它的目的是为了提高系统的性能和效率。在Java中，线程池是由ThreadPoolExecutor类实现的，ThreadPoolExecutor类提供了三个重要的参数：corePoolSize、workQueue和maximumPoolSize。corePoolSize是核心线程数，也即最小的线程数；workQueue是阻塞队列，用于存储提交的任务；maximumPoolSize是最大线程数，当提交的任务数大于corePoolSize时，会扩充线程池中线程数，直到达到maximumPoolSize。 当提交的任务数大于(workQueue.size() + maximumPoolSize)时，会触发线程池的拒绝策略。RejectedExecutionHandler接口提供了rejectedExecution方法，用于定制具体的拒绝策略的执行逻辑。 Java提供了四种默认的拒绝策略： 1. CallerRunsPolicy：当触发拒绝策略，只要线程池没有关闭的话，则使用调用线程直接运行任务。这适用于并发比较小，性能要求不高，不允许失败的情况。 2. AbortPolicy：丢弃任务，并抛出拒绝执行RejectedExecutionException异常信息。这是线程池的默认拒绝策略。 3. DiscardPolicy：直接丢弃，其他啥都没有。 4. DiscardOldestPolicy：当触发拒绝策略，只要线程池没有关闭的话，丢弃阻塞队列workQueue中的最老的一个任务，并将新任务加入。 在实际应用中，我们可以根据不同的需求选择合适的拒绝策略。例如，在高并发的情况下，可以使用CallerRunsPolicy来避免线程池的闭锁；在需要确保所有任务都被执行的情况下，可以使用AbortPolicy来抛出异常信息。 让我们通过一个简单的示例代码来演示如何使用ThreadPoolExecutor和RejectedExecutionHandler接口来实现线程池的拒绝策略。 ```java package com.cfang; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import lombok.extern.slf4j.Slf4j; @Slf4j public class T2 { public static void main(String[] args) throws Exception { int corePoolSize = 5; int maximumPoolSize = 10; long keepAliveTime = 5; BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(10); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, handler); // 提交任务 for (int i = 0; i < 20; i++) { executor.execute(new Runnable() { @Override public void run() { log.info("执行任务"); } }); } // 等待所有任务执行完成 executor.shutdown(); executor.awaitTermination(1, TimeUnit.DAYS); } } ``` 在这个示例代码中，我们创建了一个ThreadPoolExecutor实例，并将其配置为使用AbortPolicy拒绝策略。当提交的任务数大于核心线程数和最大线程数之和时，ThreadPoolExecutor将抛出RejectedExecutionException异常信息。