线程池拒绝策略

发表于 | 更新于 | 评论数：
本文字数： 1.4k

ThreadPoolExecutor类实现了ExecutorService接口和Executor接口，可以设置线程池corePoolSize，最大线程池大小，AliveTime，拒绝策略等。常用构造方法：

当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize，如果还有任务到来就会采取任务拒绝策略，通常有以下四种策略：

1
2
3
4
ThreadPoolExecutor.AbortPolicy // 丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy // 也是丢弃任务，但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy // 丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
ThreadPoolExecutor.CallerRunsPolicy // 由调用线程处理该任务

​ 我们先看一下ThreadPoolExecutor的构造方法：

1
2
3
4
5
6
public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              RejectedExecutionHandler handler)

  1. corePoolSize： 线程池维护线程的最少数量

  2. maximumPoolSize：线程池维护线程的最大数量

  3. keepAliveTime： 线程池维护线程所允许的空闲时间

  4. unit： 线程池维护线程所允许的空闲时间的单位

  5. workQueue： 线程池所使用的缓冲队列

  6. handler：线程池对拒绝任务的处理策略

​ 当我们通过execute(Runnable)方法将一个任务添加到线程池时，过程如下：

  1. 如果此时线程池中的数量小于corePoolSize，即使线程池中的线程都处于空闲状态，也要创建新的线程来处理被添加的任务。
  2. 如果此时线程池中的数量等于 corePoolSize，但是缓冲队列 workQueue未满，那么任务被放入缓冲队列。
  3. 如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量小于maximumPoolSize，建新的线程来处理被添加的任务。
  4. 如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量等于maximumPoolSize，那么通过 handler所指定的策略来处理此任务。也就是：处理任务的优先级为：核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize，如果三者都满了，使用handler处理被拒绝的任务。