美文网首页java
线程池里有几个线程在运行

线程池里有几个线程在运行

作者: Djbfifjd | 来源:发表于2020-12-07 12:58 被阅读0次

一、问题

假设有一个线程池,核心线程数为10,最大线程数也为20,任务队列为100。现在来了100个任务,线程池里现在有几个线程运行?正确的答案是“不一定”!因为并没指明是哪一种线程池机制。

二、解答

1️⃣先进队列,到最大值,再起线程

这种最容易被想到,因为 JDK 中的线程池,也就是 ThreadPoolExecutor 就是这种机制的!ThreadPoolExecutor 的 execute 方法如下:

public void execute(Runnable command) {
    if (command == null)
        throw new NullPointerException();
    int c = ctl.get();
    /**
     * 判断当前活跃线程数是否小于corePoolSize,
     * 如果小于,则调用addWorker创建线程执行任务
     **/
    if (workerCountOf(c) < corePoolSize) {
        if (addWorker(command, true))
            return;
        c = ctl.get();
    }
    /**
     * 如果不小于corePoolSize,
     * 则将任务添加到workQueue队列
     */
    if (isRunning(c) && workQueue.offer(command)) {
        int recheck = ctl.get();
        if (!isRunning(recheck) && remove(command))
            reject(command);
        else if (workerCountOf(recheck) == 0)
            addWorker(null, false);
    }
    /**
     * 如果放入workQueue失败,则创建线程执行任务,
     * 如果这时创建线程失败(当前线程数不小于maximumPoolSize时),
     * 就会调用reject(内部调用handler)拒绝接受任务。
     */
    else if (!addWorker(command, false))
        reject(command);
}
用一张图来解释如下:

如图所示,默认的机制为线程池里的核心线程数不够了,后面进来的任务会先丢队列,当队列满了,才起新线程。因此,按照这套机制,当有100个任务添加进来时,先起10个核心线程,剩下90个任务都丢进队列里,因此线程池里只有10个线程在执行!

2️⃣先起线程,到最大值,再进队列
dubbo 中,有一种线程池叫 EagerThreadPoolExecutor 线程池。该线程池的 execute 方法:

它调的还是父类的 execute 方法,也还是 ThreadPoolExecutor 中的 execute 方法!但是,它的队列是一种自定义队列,叫 TaskQueue。它的 offer 方法:

这个 offer 方法的最核心的是红框中那步,当前线程数小于最大线程数时,则直接返回 false。查看 ThreadPoolExecutor 中的 execute 方法的第二步的条件,如果 workQueue.offer 返回为 fasle,则直接进入第三步,创建新任务!

EagerThreadPoolExecutor 线程池通过自定义队列的这么一种形式,改写了线程池的机制。这种线程池的机制是核心线程数不够了,先起线程,当线程达到最大值后,后面的任务就丢进队列。

因此,如果按照这么一套机制,当100个任务添加进来时,直接会起20个线程,剩下80个任务都丢进队列!

相关文章

  • 线程池里有几个线程在运行

    一、问题 假设有一个线程池,核心线程数为10,最大线程数也为20,任务队列为100。现在来了100个任务,线程池里...

  • 线程池里有什么

    线程池里有什么?这个问题需要问吗?线程池里当然是线程啦!是,但是不准确。准确的说线程池里是工人,即Worker! ...

  • 线程池与Threadlocal

    线程池与Threadlocal 线程池: 线程池是为了使线程能够得到循环的利用,线程池里面养着一些线程,有任务需要...

  • Java多线程--JDK并发包(2)

    Java多线程--JDK并发包(2) 线程池 在使用线程池后,创建线程变成了从线程池里获得空闲线程,关闭线程变成了...

  • 多线程--精通ThreadPoolExecutor

    前言 在多线程开发中,应该避免显式创建线程,而是采用线程池里面的线程。使用线程池可以减少手动创建线程,减少线程创建...

  • 多线程相关

    在c++中使用std::thread定义线程对象,一个对象对应一个线程,几个线程可以在多线程设备上同时运行,测试用...

  • 线程池execute源码分析

    execute是我们提交一个线程的时候,线程池执行的我们运行线程的一个apiThreadPool 有几个比较重要的...

  • Java多线程(二)

    多线程 线程安全 如果有多个线程在同时运行,而这些线程可能会同时运行这段代码。程序每次运行结果和单线程运行的结果是...

  • EffectiveJava第十章第七节

    不要依赖于线程调度器 当有多个线程可以运行时,由线程调度器(thread scheduler)决定哪些线程将会运行...

  • 线程笔记二(线程安全)

    线程笔记二(线程安全) ​ 如果有多个线程在同时运行,而这些线程可能会同时运行这段代码。程序每次运行结...

网友评论

    本文标题:线程池里有几个线程在运行

    本文链接:https://www.haomeiwen.com/subject/erizwktx.html