为什么线程池只创建一个线程？

Question

我编写了代码示例：

class Test {
    public static void main(String[] args) throws InterruptedException {
        ThreadPoolExecutor executorService = new ThreadPoolExecutor(0, 100,
                2L, TimeUnit.SECONDS,
                new LinkedBlockingQueue<Runnable>());
        executorService.allowCoreThreadTimeOut(true);

        CountDownLatch countDownLatch = new CountDownLatch(20);
        long l = System.currentTimeMillis();
        for (int i = 0; i < 20; i++) {
            Thread.sleep(100);
            executorService.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        countDownLatch.countDown();
                        Thread.sleep(500);
                    } catch (Exception e) {
                        System.out.println(e);
                    }


                }
            });
        }
        executorService.shutdown();
        countDownLatch.await();

        System.out.println((System.currentTimeMillis() - l) / 100);
    }
}

每100毫秒提交一个新任务（总任务量-20）。每个任务持续时间-0.5秒。因此，可以并行执行5个任务，最佳执行时间为：20*100 500=2.5秒，池应创建5个线程

但我的实验显示为9.6秒。我打开jsvisualvm查看池创建了多少线程，我看到只创建了一个线程：

请更正我的线程池配置不正确的地方。

Answer 1

我想这种行为的答案可能来自：

ThreadPoolExecutor将根据corePoolSize（请参阅getCorePoolSize（））和maximumPoolSize（请参阅getMaximumPoolSize（））设置的边界自动调整池大小（请参阅getPoolSize（））。在方法execute（java.lang.Runnable）中提交新任务时，如果运行的线程少于corePoolSize，则会创建一个新线程来处理该请求，即使其他工作线程处于空闲状态。如果运行的线程超过corePoolSize但小于maximumPoolSize，则仅当队列已满时才会创建新线程。

（来自ThreadPoolExecutor javadoc）。

问题是：Hibernate线程是如何进入这个等式的。我的建议是：将corePoolSize从0更改为10；并将最大池大小也设置为10。

Answer 2

原因可以从ThreadPoolExecitor javadoc中找到。

任何BlockingQueue都可以用于传输和保存提交的任务。

此队列的使用与池大小相互作用：如果正在运行的线程少于corePoolSize，则Execator始终更喜欢添加新线程而不是排队。

如果corePoolsize或更多线程正在运行，则Execator始终更喜欢将请求排队而不是添加新线程。

如果请求无法排队，则会创建一个新线程，除非这将超过最大池大小，在这种情况下，任务将被拒绝。

因此，由于您的corePoolSize为0，因此不使用第一个选项，并且由于您的队列不受限制，因此不使用最后一个选项。因此，剩下的排队策略就是你得到的。

通过修改corePoolSize或工作队列的大小，可以看到不同的结果。