栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java小知识:线程池如何实现线程复用?

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java小知识:线程池如何实现线程复用?

        闲来没事突然想到这个问题,便百度了下想查看具体实现,无果。便自己翻看了下源码,以下是分析过程。

        众所周知,Java内部自带了个线程池实现 ExecutorService (虽然一直被人看不起)。随便找到其中的一个静态方法

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new linkedBlockingQueue());
    }

        可知 ExecutorService 也只是一个封装,真正的实现还得看 ThreadPoolExecutor。根据推断我们可以首先从 `ThreadPoolExecutor#execute` 找起

    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
        int c = ctl.get();
        if (workerCountOf(c) < corePoolSize) {
            if (addWorker(command, true))
                return;
            c = ctl.get();
        }
        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);
        }
        else if (!addWorker(command, false))
            reject(command);
    }

        读题解,传入的 Runnable 实例最终经过一系列安全检验被传入 addWorker 方法中,继续追踪可以看到实例(firstTask) 被传入 `ThreadPoolLocal#Worker#init` 的有参构造器中,而该 Worker 实例被添加进名为 workers 的哈希表中

         终于是找到正主了!让我们看看这个 Worker 到底是何方神圣,究竟是如何实现线程复用!

private final class Worker extends AbstractQueuedSynchronizer implements Runnable {
    public void run() {
        runWorker(this);
    }
}

        好家伙,原来 Worker 也实现了 Runnable,查看 runWorker 方法可知,当当前任务执行后task置空,Worker 线程调用 getTask 方法从任务队列中获取新任务并执行。至此便实现了一个 Worker 线程执行多个 Runnable 任务的功能。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/287434.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号