Java线程池maximumPoolSize和workQueue哪个先饱和?

java,maximumpoolsize,workqueue · 浏览次数 : 0

小编点评

结论:真正的饱和顺序是corePoolSize -> workQueue -> maximumPoolSize。线程池参数核心线程数corePoolSize、最大线程数maximumPoolSize、非核心线程空闲等待时间keepAliveTime、时间单位unit和用于存储任务的阻塞队列workQueue共同决定了线程池的行为。 验证案例1: 线程池大小为5,最大线程数为10,keepAliveTime为60秒,使用LinkedBlockingQueue作为工作队列。 任务数量为6,预期输出结果为:每6个任务一次打印,共打印3次。 验证案例2: 线程池大小为5,最大线程数为10,keepAliveTime为60秒,使用LinkedBlockingQueue作为工作队列。 任务数量为16,预期输出结果为:前6个任务打印5次,接下来的任务打印6次,最后4个任务打印4次。 通过以上验证,我们可以得出结论:当线程池的corePoolSize已满时,新任务会被放入workQueue中。当任务数量超过corePoolSize但小于等于maximumPoolSize时,线程池会创建新线程来执行任务;当任务数量超过maximumPoolSize时,线程池会继续创建新线程,直到所有任务都被执行完毕。

正文

先说结论,真正的饱和顺序是corePoolSize -> workQueue -> maximumPoolSize。


我们都知道,线程池有以下参数

ThreadPoolExecutor(int corePoolSize, //核心线程数
                  int maximumPoolSize, //
                  long keepAliveTime,
                  TimeUnit unit,
                  BlockingQueue<Runnable> workQueue)
  • corePoolSize:核心线程池大小,即使没有任务,这些线程也会一直存活。
  • maximumPoolSize:最大线程池大小,当任务量超过核心线程数时,最多可以创建这么多线程。
  • keepAliveTime:非核心线程在空闲时等待新任务的最长时间。
  • unit:keepAliveTime 的时间单位。
  • workQueue:阻塞队列,用于存储待执行的任务。常见的阻塞队列实现有 ArrayBlockingQueue、LinkedBlockingQueue 和 SynchronousQueue 等。

我之前的理解是,当线程数达到corePoolSize后,新任务到来会创建新线程直到达到maximumPoolSize,当达到maximumPoolSize后,新任务才会放到workQueue里。

但其实,这一直都是错误的理解,真正的饱和顺序是corePoolSize->workQueue->maximumPoolSize。

下面开始验证

ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(10));
for (int i = 0; i < 6; i++) {
    int finalI = i;
    executor.submit(() -> {
        System.out.println(Thread.currentThread().getName() + " " + finalI);
        try {
            Thread.sleep(5000L);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    });
}
executor.shutdown();

若corePoolSize满了后新任务是创建新线程,那么这里应该一次打印6条日志。

若corePoolSize满了之后新任务放到workQueue里,那么这里应该打印两次,第一次5条,第二次1条。

打印结果

由此可见符合第二种情况,为了证明可信度下面再验证一种情况

ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(10));
for (int i = 0; i < 16; i++) {
    int finalI = i;
    executor.submit(() -> {
        System.out.println(Thread.currentThread().getName() + " " + finalI);
        try {
            Thread.sleep(5000L);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    });
}
executor.shutdown();

按照上面的结论推测,当我们有16个要执行的任务,首先会占用5个核心线程,然后放10个任务到阻塞队列,剩下的1个加上核心线程数是6个,达不到最大线程数,所以会创建活动线程,此时线程池中会有6个可用线程。所以会分三次打印结果,第一次6条,第二次6条,第三次4条。下面验证推测

验证成功!

与Java线程池maximumPoolSize和workQueue哪个先饱和?相似的内容:

Java线程池maximumPoolSize和workQueue哪个先饱和?

先说结论,真正的饱和顺序是corePoolSize -> workQueue -> maximumPoolSize。 我们都知道,线程池有以下参数 ThreadPoolExecutor(int corePoolSize, //核心线程数 int maximumPoolSize, // long ke

Java多线程-ThreadPool线程池-1(三)

开完一趟车完整的过程是启动、行驶和停车,但老司机都知道,真正费油的不是行驶,而是长时间的怠速、频繁地踩刹车等动作。因为在速度切换的过程中,发送机要多做一些工作,当然就要多费一些油。 而一个Java线程完整的生命周期就包括: 1、T1:创建(启动) 2、T2:运行(行驶) 3、T3:销毁(停车) 而T

【后端面经-java】java线程池满的处理策略

本文对java线程池做了具体介绍,并且讨论了java线程池满了之后的拒绝策略。

万字长文详解Java线程池面试题

大家好,我是王有志。今天是《面霸的自我修养》第 6 篇文章,我们一起来看看面试中会问到哪些关于线程池的问题吧。

10分钟带你徒手做个Java线程池

摘要:花10分钟开发一个极简版的Java线程池,让小伙伴们更好的理解线程池的核心原理。 本文分享自华为云社区《放大招了,冰河带你10分钟手撸Java线程池,yyds,赶快收藏吧》,作者:冰 河。 Java线程池核心原理 看过Java线程池源码的小伙伴都知道,在Java线程池中最核心的类就是Threa

Java面试题:线程池内“闹情绪”的线程,怎么办?

在Java中,线程池中工作线程出现异常的时候,默认会把异常往外抛,同时这个工作线程会因为异常而销毁,我们需要自己去处理对应的异常,异常处理的方法有几种:在传递的任务中去处理异常,对于每个提交到线程池中的执行的任务,可以提前通过异常进行捕获,这样即便出现了异常,也不会影响线程池中的工作线程,使用Fut...

Java多线程-ThreadPool线程池-2(四)

线程池是个神器,用得好会非常地方便。本来觉得线程池的构造器有些复杂,即使讲清楚了对今后的用处可能也不太大,因为有一些Java定义好的线程池可以直接使用。但是(凡事总有个但是),还是觉得讲一讲可能跟有助于理解后面的常用线程池,所以该打脸还是打吧 因为直接结合代码看会更清楚一些,所以我把带注释的代码贴出

Java异步判断线程池所有任务是否执行完成的方法

本文详细介绍了Java异步判断线程池所有任务是否执行完成的方法,分别介绍了使用ExecutorService和CountDownLatch的方法示例、使用ExecutorService的invokeAll方法和Future列表的方法示例、使用ExecutorService来异步执行多个Callabl...

Java多线程-ThreadPool线程池-3(五)

除了可以通过ThreadPoolExecutor自定义线程池外,同Stream API中的Collectors一样,多线程里的Executors类也提供了一组相关的线程池工具,可以直接拿来用,不用考虑用什么队列合适的问题。 Javac除了传统的四大线程池工具: 1、newFixedThreadPoo

【转帖】JVM 内存模型与垃圾回收

文章目录 1. JVM内存模型1.1. 程序计数器 (线程私有)1.2. Java 虚拟机栈 (线程私有)1.3. 本地方法栈 (线程私有)1.4. Java 堆 (线程共享)1.5. 方法区 (线程共享)1.6. 运行时常量池 (线程共享)1.7. 直接内存 (堆外内存) 2. 垃圾查找算法2.1