программа не завершается сразу, когда все задачи ExecutorService сделаны

Question

Я положил кучу работоспособных объектов в ExecutorService:

// simplified content of main method 
ExecutorService threadPool = Executors.newCachedThreadPool(); 
for(int i = 0; i < workerCount; i++) { 
    threadPool.execute(new Worker()); 
} 

Я ожидаю, что моя программа/процесс немедленно прекратить после того, как все рабочие сделали. Но согласно моему журналу, это займет еще 20-30 секунд, пока это не произойдет. Работники не выделяют никаких ресурсов, фактически они ничего не делают на данный момент.

Не поймите меня неправильно, это не очень важная проблема для меня, я просто пытаюсь понять, что происходит, и мне интересно, нормальное поведение.

Answer 1

Executors.newCachedThreadPool() использует Executors.defaultThreadFactory() для своих ThreadFactory. defaultThreadFactory javadocs говорят, что «каждый новый поток создается как не-daemon поток» (выделено мной). Итак, потоки, созданные для newCachedThreadPool, являются не-демонами. Это означает, что они будут препятствовать естественному выходу JVM («естественно», я имею в виду, что вы все равно можете позвонить System.exit(1) или убить программу, чтобы заставить JVM остановиться).

Причина, по которой приложение заканчивается вовсе, заключается в том, что каждая нить, созданная в пределах newCachedThreadPool, разрывается и закрывается после некоторого времени бездействия. Когда последний из них закрывается, если ваше приложение не имеет ни одного не-демона, то оно прекратится.

Вы можете (и должны) закрыть ExecutorService вниз вручную через shutdown или shutdownNow.

См. Также JavaDoc для Thread, в котором говорится о демонах.

Answer 2

Из javadoc для Executors.newCachedThreadPool():

Нити, которые не использовались в течение шестидесяти секунд прекращается, и удаляется из кэша.

Это, как правило, хорошая идея, чтобы позвонить shutdown() на ExecutorService, если вы знаете, что никакие новые задачи не будут представлены в нем. Затем все задачи в очереди будут завершены, но служба немедленно отключится.

(Альтернативно, если вам все равно, выполняются ли все задачи, например, если они обрабатывают фоновые вычисления, которые не имеют значения после того, как ваш основной интерфейс исчезнут, - тогда вы можете создать ThreadFactory, который устанавливает все потоки в этот пул будет демоном.)

Answer 3

Я ожидаю, что моя программа/процесс остановится сразу после того, как все работники будут сделаны. Но согласно моему журналу, это займет еще 20-30 секунд, пока это не произойдет. Работники не выделяют никаких ресурсов, фактически они ничего не делают на данный момент.

Проблема в том, что вы не закрываете свой ExecutorService. После того, как вы отправите все задания в службу, вы должны завершить работу службы, или JVM не будет завершаться, если все потоки в нем не являются потоками демона. Если вы не отключите пул потоков, то любые потоки, связанные с ExecutorService, опять же, если не демон, остановят JVM от завершения. Если вы отправили какие-либо задачи в кешированный пул потоков, вам придется подождать, пока потоки перейдут на тайм-аут и получат прибыль до завершения JVM.

ExecutorService threadPool = Executors.newCachedThreadPool(); 
for(int i = 0; i < workerCount; i++) { 
    threadPool.execute(new Worker()); 
} 
// you _must_ do this 
threadPool.shutdown(); 

Запуск темы, как демон, скорее всего, не то, что вы хотите сделать, потому что ваше приложение может перестать до того задача была завершена, и все задачи, будет немедленно прекращена в то время. Из 178 раз мы используем классы ExecutorService в нашем производственном коде, только 2 из них были запущены как потоки демонов. Остальные нормально завершают работу.

Если вам необходимо принудительно отключить ExecutorService, когда приложение выходит, то с помощью shutdownNow() с правильной обработкой флагов прерывания потока в порядке.

Answer 4

Для многопоточной обработки ExecutorService Решение threadPool.shutdown();

Answer 5

В основном на ExecutorService вызове Shutdown(), а затем awaitTermination():

ExecutorService taskExecutor = Executors.newFixedThreadPool(4); 
while(...) { 
    taskExecutor.execute(new MyTask()); 
} 
taskExecutor.shutdown(); 
try { 
    taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); 
} catch (InterruptedException e) { 
    ... 
}