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


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


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

    ThreadPoolExecutor(int corePoolSize, //核心线程数
                      int maximumPoolSize, //
                      long keepAliveTime,
                      TimeUnit unit,
                      BlockingQueue 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条。下面验证推测

    验证成功!


    __EOF__

  • 本文作者: 救苦救难韩天尊
  • 本文链接: https://www.cnblogs.com/gilbertdu/p/18245918
  • 关于博主: 评论和私信会在第一时间回复。或者直接私信我。
  • 版权声明: 本博客所有文章除特别声明外,均采用 BY-NC-SA 许可协议。转载请注明出处!
  • 声援博主: 如果您觉得文章对您有帮助,可以点击文章右下角推荐一下。
  • 相关阅读:
    htb_solarlab
    总结改变和获取 url 的方法 (包括 umi,react-router,原生)
    在哪些场景下不建议自增数据库主键
    【SpringBoot实践】事务和事务传播机制&失效原因&正确使用事务的建议
    使用 Footprint Analytics, 快速搭建区块链数据应用
    C#有关里氏替换原则的经典问题答疑
    2024.05.21 校招 实习 内推 面经
    判断前端和后端bug,赶紧来扫个盲!
    Qt实现生成唯一标识ID
    Vue-2.3v-model原理
  • 原文地址:https://www.cnblogs.com/GilbertDu/p/18245918