Java线程池中的拒绝策略

• 一、什么是线程池中的拒绝策略？
• 二、拒绝策略有哪些
• • 1、RejectedExecutionHandler（拒绝执行处理程序）
  • • 丢弃策略（DiscardPolicy ）
    • 中止策略（AbortPolicy ）
    • 优先处理策略（CallerRunsPolicy ）
    • 丢弃最老任务（DiscardOldestPolicy ）

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)

1、谈拒绝策略前，需要先说一下Java中的线程池ThreadPoolExecutor，对于Java中线程池的使用一般都是通过new ThreadPoolExecutor来创建，而通过其构造方法可以发现对于其创建需要7个参数：

在这里插入代码片

 1. int corePoolSize -----------------------------------核心线程数
 2. int maximumPoolSize---------------------------------最大线程数
 3. long keepAliveTime----------------------------------时间大小
 4. TimeUnit unit---------------------------------------时间类型
 5. BlockingQueue workQueue-------------------任务队列
 6. ThreadFactory threadFactory-------------------------创建线程的工厂
 7. RejectedExecutionHandler handler--------------------拒绝策略

对于这个7个参数线程池是如何使用的呢，接着往下看，线程池的执行流程：
1、当向线程池提交任务时，会去创建核心线程
2、当任务太多，核心线程来不及处理时，会将任务先放入任务队列
3、当任务队列满了，会去创建新的线程处理任务，但不会超过最大线程数
4、当线程空闲超过我们设置的时间大小，则回去销毁（核心线程数-最大线程数）之间的线程
5、当队列已满，总线程数已达我们设置的最大线程数时，新的任务进来则会触发我们设置的拒绝策略

总结：也即是说在线程池队列已满，且已创建到最大线程数量时，新的任务提交至线程池,线程池无法处理新的任务，则会对新的任务线程进行丢弃，抛异常，优先处理，丢弃队列中最久等待任务，这些对新的任务线程的处理则称之为线程池的拒绝策略

线程池中的拒绝策略都实现了RejectedExecutionHandler下rejectedExecution方法：

public interface RejectedExecutionHandler {

    
    void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}

public static class DiscardPolicy implements RejectedExecutionHandler {
        
        public DiscardPolicy() { }

        
        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
        }
    }

1、可以在方法rejectedExecution看到，没有任何的代码处理逻辑，也就是对新的任务不做任何处理，翻译过来就是丢弃策略，业务中慎用。

public static class AbortPolicy implements RejectedExecutionHandler {
        
        public AbortPolicy() { }

        
        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            throw new RejectedExecutionException("Task " + r.toString() +
                                                 " rejected from " +
                                                 e.toString());
        }
    }

1、在代码中可见，在rejectedExecution方法中抛出了RejectedExecutionException异常，会对代码的运行进行中止。

public static class CallerRunsPolicy implements RejectedExecutionHandler {
        
        public CallerRunsPolicy() { }

        
        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) {
                r.run();
            }
        }
    }

1、对新的任务进行优先执行，直接调用其run方法

public static class DiscardOldestPolicy implements RejectedExecutionHandler {
        
        public DiscardOldestPolicy() { }

        
        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) {
            	//丢弃队列中最老，最先进来的任务
                e.getQueue().poll();
                e.execute(r);
            }
        }
    }

1、拿到队列，调用队列的poll方法对队列中最老的任务进行丢弃，再将新的任务放入队列中