栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

newFixedThreadPool的内部工作

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

newFixedThreadPool的内部工作

仅供参考:这是一个非常简单的线程池实现。

class MyThreadPool implements java.util.concurrent.Executor {    private final java.util.concurrent.BlockingQueue<Runnable> queue;    public MyThreadPool(int numThreads) {        queue = new java.util.concurrent.linkedBlockingQueue<>();        for (int i=0 ; i<numThreads ; i++) { new Thread(new Runnable(){     @Override     public void run() {         while(true) {  queue.take().run();         }     } }).start();        }    }    @Override    public void execute(Runnable command) {        queue.put(command);    }}

这不会编译,因为我没有处理InterruptedException,并且在 真实的
线程池中,您还希望处理给定抛出的异常

command
,但是它应该使您大致了解线程池做。

它创建一个队列和任意数量的 工作线程 。工作线程相互竞争以使用队列中的 命令
。队列为

BlockingQueue
,因此,只要队列为空,工作人员都会睡觉。

其他线程可能会产生新命令(即

Runnable
对象),并调用该
execute(command)
方法以将新命令放入队列。这些命令将由工作线程以大约与入队相同的顺序执行(即,将调用其运行方法)。


  • 大概是因为工作者A可以从队列中选择一个新命令,然后在调用该命令的
    .run()
    方法之前丢失其时间片。然后,其他工作程序可以从队列中选择其他命令并执行它们,然后调度程序允许工作程序A重新运行。


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

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

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