ThreadPoolExecutor的构造方法的最后一个参数指定了拒绝策略,
当提交给线程池的任务量超过实际承载能力时,如何处理?
即线程池中的线程已经用完,等待队列也满了,无法为新提交的任务服务,可以通过拒绝策略来处理这个问题。

  • 四种拒绝策略:

               1.AbortPolicy策略:会抛出异常
               2.CallerRunPolicy策略:只要线程池没关闭,会在调用者线程中运行当前被丢弃的任务
               3.DiscardOldestPolicy策略:任务队列中最老的任务丢弃,尝试再次提交新任务
               4.DiscardPolicy策略:直接丢弃无法处理的任务
    
Executor工具类提供的静态方法返回的线程池默认的拒绝策略是AbortPolicy策略,抛出异常
如果内置的策略无法满足实际需求,可以扩展RejectedExecutionHandler接口

1.AbortPolicy策略

    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());
        } 
    }

2.CallerRunPolicy策略

    public static class CallerRunsPolicy implements RejectedExecutionHandler {

        public CallerRunsPolicy() { }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) { //如果线程池没有关闭,则将当前任务尝试执行一次
                r.run();
            }
        }
    }

3.DiscardOldestPolicy策略

   public static class DiscardOldestPolicy implements RejectedExecutionHandler {

        public DiscardOldestPolicy() { }


        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
            if (!e.isShutdown()) { 
                e.getQueue().poll(); //弹出并移除队头中的一个任务并执行当前的任务
                e.execute(r);
            }
        }
    }

4.DiscardPolicy策略

   public static class DiscardPolicy implements RejectedExecutionHandler {

        public DiscardPolicy() { }

        public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {

        } //方法为空,什么都不做即为:任务丢弃
    }

个人实现拒绝策略,只需要实现借口: implements RejectedExecutionHandler 就可以了。

在jdk默认实现中使用的是拒绝异常策略:

 private static final RejectedExecutionHandler defaultHandler = new AbortPolicy();

可以看到在定义的默认策略中使用的是AbortPolicy 即为直接抛出异常:

RejectedExecutionException