Java ThreadPoolExecutor — фиксированныйThreadPool ActiveCount = 0, QueueSize = 1, PoolSize = 10

Я не знаю, является ли это «хорошим» ответом, но я добавлю его, поскольку он кажется немного неочевидным.

Когда я тестирую код ОП с помощью очень короткого тестового примера (задачи), я получаю результаты, аналогичные результатам ОП. Это можно считать распространенной проблемой микротестов. Или это также может быть проблема с плохо разработанным производственным кодом, отправляющим очень короткие задачи для выполнения в отдельный поток. Например:

   public static void main( String[] args ) {
      ExecutorService es = Executors.newFixedThreadPool( 10 );
      System.out.println( es );
      for( int i = 0; i < 20; i++ )
         es.execute( () -> {System.out.println( "test" ); } );
//         es.execute( FixedThreadPool::test );
      System.out.println( es );
      es.shutdown();
   }

Выдает такой вывод:

test
test
test
java.util.concurrent.ThreadPoolExecutor@7506e922[Running, pool size = 10, active threads = 2, queued tasks = 10, completed tasks = 8]
test
test
test (more "test" lines removed)

С другой стороны, если я добавлю к тестовому заданию более длительную задержку, например, 2-секундную задержку сна, то все 10 потоков в исполнителе будут отображаться как активные.

public class FixedThreadPool {

   public static void main( String[] args ) {
      ExecutorService es = Executors.newFixedThreadPool( 10 );
      System.out.println( es );
      for( int i = 0; i < 20; i++ )
         es.execute( FixedThreadPool::test );
      System.out.println( es );
      es.shutdown();
   }

   private static void test() {
      try {
         System.out.println( "test" );
         Thread.sleep( 2000 );
      } catch( InterruptedException ex ) {
         // exit
      }
   }
}

Выход:

test
test
java.util.concurrent.ThreadPoolExecutor@7506e922[Running, pool size = 10, active threads = 10, queued tasks = 10, completed tasks = 0]
test
test
test (more "test" lines trimmed)

Это артефакт из-за условий гонки.

Если вы посмотрите на пример, предоставленный markspace:

    public static void main(String[] args) {
       ExecutorService es = Executors.newFixedThreadPool(10);
       System.out.println(es);
       for (int i = 0; i < 20; i++) {
          es.execute(() -> System.out.println("test"));
       }
       System.out.println(es);
       es.shutdown();
    }

Он создает фиксированный пул потоков размером 10, а затем отправляет 20 задач в короткой последовательности.

Для первых 10 задач рабочие потоки создаются и запускаются немедленно, остальные 10 задач добавляются в рабочую очередь.

Создаются 10 рабочих потоков, о чем свидетельствует «размер пула = 10»:

• Перед отправкой первой задачи при печати состояния пула потоков выводится «размер пула = 0».
• После отправки задач распечатайте статус пула потоков, выведите «размер пула = 10».

Когда вы распечатываете состояние пула потоков с помощью System.out.println(es); метода пулов потоков toString()собирает некоторую статистику:

Возвращает строку, идентифицирующую этот пул, а также его состояние, включая сведения о состоянии выполнения и предполагаемом количестве рабочих и задач.

Эти значения неточны, поскольку метод toString() не приостанавливает ни один исполнитель во время сбора статистики.

• Работник, выполняющий задачу в данный момент, считается «активным».
• Работник, завершивший задачу и получающий следующую задачу, не активен.
• цикл по списку рабочих выполняется быстрее, чем рабочие, извлекающие задачи из очереди задач (поскольку цикл по списку не требует блокировки, выборка задач из очереди задач требует блокировки) Поэтому некоторые рабочие процессы, которые только что завершили задачу и находятся в состоянии получения следующей задачи, не будут отправлены.