Почему threadpool создает только один поток?

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, чтобы увидеть, сколько потоков пула создает и я вижу, что только один поток был создан:

, пожалуйста, поправьте где моя конфигурация threadPooll неправильно.

Answer 1

Я предполагаю ответ на такое поведение может быть укоренена в:

ThreadPoolExecutor будет автоматически регулировать размер пула (см getPoolSize()) в соответствии с границами, установленными corePoolSize (см getCorePoolSize()) и maximumPoolSize (см. getMaximumPoolSize()). Когда новая задача отправляется при выполнении метода (java.lang.Runnable), и выполняется меньше потоков corePoolSize, для обработки запроса создается новый поток, даже если другие рабочие потоки простаивают. Если существует больше, чем corePoolSize, но меньше потоков MaximumPoolSize, новый поток будет создан только в том случае, если очередь заполнена.

(from ThreadPoolExecutor javadoc).

Вещь: как спальные темы, входящие в это уравнение. Мое предложение: изменить corePoolSize от 0 до 10; и установите максимальный размер пула на 10.

Answer 2

Причина может быть найдена с ThreadPoolExecutor javadoc.

Любое BlockingQueue может использоваться для передачи и хранения предоставленных задач.

Использование этой очереди взаимодействует с бассейном проклейки: Если меньше, чем corePoolSize потоков выполняются, Исполнитель всегда предпочитает добавлять новый поток, а не в очередь.

Если corePoolSize или более потоки равны , Executor всегда предпочитает очередность запроса, а не , добавляя новый поток.

Если запрос не может быть поставлен в очередь, новый поток будет создан , если это не будет превышать maximumPoolSize, и в этом случае задача будет отклонена.

Поэтому, поскольку ваш corePoolSize равен 0, первый вариант не используется, и поскольку ваша очередь не ограничена, последний параметр не используется. Поэтому оставшаяся стратегия очередей - это то, что вы получаете.

Различные результаты можно увидеть, изменив corePoolSize или размером workQueue.