简介

 java里面的线程池引入了一个叫拒绝执行的策略模式,意思也就是说当池子满的时候该如何执行还在不断往里面添加的一些任务。

场景

  1. 如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。

  2. 如果此时线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。

  3. 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。

  4. 如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。

处理任务的优先级

​ 核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。

策略详情

  1. ThreadPoolExecutor.DiscardPolicy(): 丢弃被拒绝的任务(不执行),底层的实现是直接调用空方法,什么都不做
  2. ThreadPoolExecutor.AbortPolicy(): 抛出java.util.concurrent.RejectedExecutionException异常
  3. ThreadPoolExecutor.DiscardOldestPolicy(): 丢弃队列中最老的任务
  4. ThreadPoolExecutor.CallerRunsPolicy(): 直接在 execute 方法的调用线程中运行被拒绝的任务;如果调用者已关闭,则会丢弃该任务