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)；

我不理解这一点“没有新线程将被创建，但工作将等待一个线程空闲。”我认为当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，而且在实际的线程池中，您还希望处理给定的命令可能引发的异常，但它应该可以让您大致了解线程池的作用。

它创建一个队列和任意数量的工作线程。工作线程相互竞争以使用来自队列的命令。队列是一个blockingqueue，因此每当队列为空时，工作人员都将Hibernate。

null