newFixedThreadPool的内部工作

Question

请帮助我了解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。

Answer 1

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

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