ThreadPoolExecutor

2024-04-11 23:31:49

记录一下ThreadPoolExecutor类的常见知识点。

下边是全参构造函数

public ThreadPoolExecutor(
int corePoolSize,//线程池的核心线程数量
int maximumPoolSize,//线程池的最大线程数
long keepAliveTime,//当线程数大于核心线程数时，多余的空闲线程存活的最长时间
TimeUnit unit,//时间单位
BlockingQueue<Runnable> workQueue,//任务队列，用来储存等待执行任务的队列
ThreadFactory threadFactory,//线程工厂，用来创建线程，一般默认即可
RejectedExecutionHandler handler//拒绝策略，当提交的任务过多而不能及时处理时，我们可以定制策略来处理任务) {
        if (corePoolSize < 0 ||
            maximumPoolSize <= 0 ||
            maximumPoolSize < corePoolSize ||
            keepAliveTime < 0)
            throw new IllegalArgumentException();
        if (workQueue == null || threadFactory == null || handler == null)
            throw new NullPointerException();
        this.corePoolSize = corePoolSize;
        this.maximumPoolSize = maximumPoolSize;
        this.workQueue = workQueue;
        this.keepAliveTime = unit.toNanos(keepAliveTime);
        this.threadFactory = threadFactory;
        this.handler = handler;
    }

ThreadPoolExecutor 3 个最重要的参数：

corePoolSize : 核心线程数定义了最小可以同时运行的线程数量。
maximumPoolSize : 当队列中存放的任务达到队列容量的时候，当前可以同时运行的线程数量。
workQueue: 当新任务来的时候会先判断当前运行的线程数量是否达到核心线程数，如果达到的话，新任务就会被存放在队列中。

举个栗子，设置3个参数如下

corePoolSize=3，
maximumPoolSize=5，
new ArrayBlockingQueue<Runnable>(10)

先放个图

BlockingQueue<E>有多个实现类，ArrayBlockingQueue<E>只是其中一个，他是一个有界队列，而LinkedBlockingQueue<E>则是*队列。

任务一个一个进来，在任务数小于等于3的时候，每次来新任务都会创建新线程（即核心线程）；当第四个进来的时候，如果有空闲的核心线程，则执行此任务，否则会被放到工作队列中，等待有核心线程空闲出来去执行；如果处理的慢，工作队列满了（达到了10个），再进来新任务，会创建新线程来执行；如果队列一直是满的，进来的新任务会持续创建新线程，一直到池子里的线程数等于maximumPoolSize，之后再有进来的任务，就会触发饱和策略。

如果使用LinkedBlockingQueue<E>，则队列永远不会满，corePoolSize 和maximumPoolSize 一直是相同的。

ThreadPoolExecutor其他常见参数:

keepAliveTime:当线程池中的线程数量大于 corePoolSize 的时候，如果这时没有新的任务提交，核心线程外的线程不会立即销毁，而是会等待，直到等待的时间超过了 keepAliveTime才会被回收销毁；
unit : keepAliveTime 参数的时间单位；
threadFactory :executor 创建新线程的时候会用到；
handler :饱和策略。关于饱和策略下面单独介绍一下。

如果当前同时运行的线程数量达到最大线程数量并且队列也已经被放满了任务时，ThreadPoolTaskExecutor 定义一些策略:

ThreadPoolExecutor.AbortPolicy：抛出 RejectedExecutionException来拒绝新任务的处理。

ThreadPoolExecutor.CallerRunsPolicy：调用执行自己的线程运行任务，也就是直接在调用execute方法的线程中运行(run)被拒绝的任务，如果执行程序已关闭，则会丢弃该任务。因此这种策略会降低对于新任务提交速度，影响程序的整体性能。如果您的应用程序可以承受此延迟并且你要求任何一个任务请求都要被执行的话，你可以选择这个策略。

ThreadPoolExecutor.DiscardPolicy：不处理新任务，直接丢弃掉。

ThreadPoolExecutor.DiscardOldestPolicy：此策略将丢弃最早的未处理的任务请求。

码农公寓

相关文章