当前位置: 首页 > 面试题库 >

newFixedThreadPool的内部工作

梁丘经艺
2023-03-14
问题内容

请帮助我了解newFixedThreadPool(或Cached)的内部流程

当我们编写以下语句时,ExecutorService e = Executors.newFixedThreadPool(3);

  1. e.execute(runaable1);
  2. e.execute(runaable2);
  3. e.execute(runaable3);
  4. e.execute(runaable4);
  5. e.execute(runaable5);

直到3个execute方法,将创建三个线程,当第4个execute方法被调用时,将不会创建新线程,但工作将等待线程释放。

我不理解这一点,“不会创建新线程,但是工作将等待线程释放。”
我认为将runnable1提供给第一个创建的线程时,一旦runnable1的run方法将完成,Thread1的run也将完成,thread1将无法调用runnable4的run方法。因此,java如何仅用3个线程来执行5个Runnable。


问题答案:

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

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重新运行。


 类似资料:
  • 请帮助我理解newFixedThreadPool(或Cached)的内部流 当我们编写下面的语句时,ExecutorService e=executors.NewFixedThreadPool(3); e.execute(runaable1); e.execute(runaable2); e.execute(runaable3); e.execute(runaable4); e.execute(r

  • 可以通过调用Executors类的静态newFixedThreadPool()方法获得固定的线程池。 语法 (Syntax) ExecutorService fixedPool = Executors.newFixedThreadPool(2); 哪里 最多2个线程将处于活动状态以处理任务。 如果提交的线程超过2个,则它们将保留在队列中,直到线程可用。 如果线程在执行器执行关闭期间因故障而终止,

  • 我有一个xml布局,它有以下视图:滚动视图->Relationvelayout->Some views+Tablayout+ViewPager->RecylerView(在ViewPager的片段中)。ViewPager有一些固定的高度(保持它“wrap_content”根本不会显示它)。现在的问题是Recylerview永远不会滚动。我已经尝试了几个已经发布的解决方案,比如在“嵌套滚动视图”中包

  • 本文向大家介绍Java中HashMap的内部工作,包括了Java中HashMap的内部工作的使用技巧和注意事项,需要的朋友参考一下 函数“ hashCode”用于获取Java中对象的哈希码。这是超类Object的对象。它以整数形式返回对象引用的内存。这是一个本机函数,这意味着Java中没有直接方法可用于获取对象的引用。 为了使HashMap的性能更好,请正确使用。基本上,此函数用于计算存储区和索引

  • 问题内容: 在Spring中,如果我没记错的话,以下两个语句是相同的: spring如何知道’type’(第二个版本)的变量名。我的印象是,除非使用-g标志进行编译(包括调试信息),否则将从类文件中删除此信息。 问题答案: 简短的说法是,参数名显然是在其中编译的,如果没有编译,则会出现异常,表明Spring MVC无法推断出参数名。也就是说,参数名称并不总是存储在字节码中,但是看起来好像是,Spr

  • 我有以下代码: } 我对ThreadPoolExecitor工作方式的了解是否正确: 如果NumberOfThreadRunning 根据第3点。我应该能够使用ThreadPoolExecutor执行20个任务。 为什么上述代码的输出是?