newFixedThreadPool 的内部工作原理

Question

请帮助我理解 newFixedThreadPool （或 Cached）的内部流程

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

1. e.执行（runaable1）；
2. e.执行（runaable2）；
3. e.执行（runaable3）；
4. e.执行（runaable4）；
5. e.执行（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，但它应该让您大致了解线程池是什么做。

它创建一个队列和任意数量的工作线程。工作线程相互竞争以使用队列中的命令。队列是 a BlockingQueue，因此每当队列为空时，工作人员都会休眠。

其他线程可能会产生新的命令（即Runnable对象），并调用该execute(command)方法将新命令放入队列中。工作线程将按照与它们排队的顺序大致相同的顺序执行命令（即，将调用它们的运行方法）。

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