Когда исполнительService.shutdown(); следует называть

Question

У нас есть метод GetDataParallel(), который может быть вызван многими клиентами в настоящее время, и мы используем ExecutorService для вызова MyCallable внутри него. Однако я обнаружил, что не вызвал бы execorService.shutdown(); приложение никогда не выходит, поэтому почему приложение не может выйти, мы должны закрыть все потоки пула потоков вручную до выхода приложения? и в среде обслуживания я думаю, что нам не нужно вызывать executorService.shutdown(); чтобы поддерживать приложение, верно?

import java.util.ArrayList; 
import java.util.List; 
import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 

public class MultiThreading { 

    static ExecutorService executorService = Executors.newFixedThreadPool(100); 
    private List<String> _BusinessUnits= new ArrayList<String>(); 
    public static void main(String[] args) throws Exception { 

     MultiThreading kl =new MultiThreading(); 
     kl.GetDataParallel(); 
     Thread.sleep(10000); 
     System.out.println("111111111"); 
     //executorService.shutdown(); 

    } 

    public void GetDataParallel() throws Exception 
    { 
     _BusinessUnits.add("BU1"); 
     _BusinessUnits.add("BU2"); 
     _BusinessUnits.add("BU3"); 

     for(final String v : _BusinessUnits) 
     { 
      ExecutorServiceTest.executorService.submit(new MyCallable()); 
     } 
    } 
} 

    class MyCallable implements Callable { 
    @Override 
    public String call() throws Exception { 
     Thread.sleep(1000); 
     //return the thread name executing this callable task 
     System.out.println(Thread.currentThread().getName()); 
     return Thread.currentThread().getName(); 
    } 
} 

Answer 1

В Java есть два варианта нитей (конечно, в зависимости от того, как вы на них смотрите). «Пользовательские» потоки и потоки «Демон». Ваша заявка заканчивается в одном из следующих случаев:

1. Вы называете System.exit()
2. У вас нет User темы, оставленной в вашем приложении. Это объясняется here.

Обратите внимание, что ваша main функции выполняется с помощью виртуальной машины Java на нитке «User», что означает, что до тех пор, пока вы не закончили свою main функции. Большинство многопоточных приложений будут запускать основную функцию только для запуска всех необходимых потоков.

Идея потоков Daemon заключается в том, что вы можете что-то делать (регулярно), но если все остальные задачи выполняются, это не помешает выходу приложения.

По умолчанию новые потоки - это темы «Non Daemon», то же самое касается потоков, охваченных вашим ExecutorService. Если вы хотите изменить это, вы должны создать свой собственный ThreadFactory. A ThreadFactory позволяет вручную создавать потоки для вашего ExecutorService, он будет вызываться, когда ExecutorService нуждается в новом потоке. Вот пример, который создал «DAEMON» нитей:

public class DaemonThreadFactory implements ThreadFactory 
{ 

    @Override 
    public Thread newThread(final Runnable r) 
    { 
     Thread t = new Thread(r); 
     t.setDaemon(true); 
     return t; 
    } 
} 

Это может быть использовано при создании сервиса Исполнитель:

ExecutorService service = Executors.newFixedThreadPool(100, new DaemonThreadFactory()); 

Обратите внимание, что это также способ дать свои темы на заказ имена, которые очень полезны, так как многие logframeworks записывают имя потока (и показывает его отладчик).

Если вы должны были сделать это, в своем приложении он сразу же выйдет, потому что вы создаете потоки «Daemon», поэтому вам придется либо сохранить еще один поток в живых (это может быть сделано неявно другой структурой, например, если у вас есть GUI).

Альтернативой является вызов вручную System.exit(). Обычно вызывать код System.exit() в вашем коде не рекомендуется. В основном потому, что это не позволяет хорошо рефакторинг, повторное использование, тестирование и многие точки выхода делают ваше приложение непредсказуемым. Чтобы обойти эти проблемы, вы можете создать функцию обратного вызова, которая обрабатывает событие завершения задания. В этом приложении вы вызываете System.exit(), ваш тестовый код или другие приложения могут делать что-то еще.

Answer 2

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

В случае Службы вы должны позвонить shutdown перед остановкой выполнения Сервиса. Напр. в случае веб-приложения метод contextDestroyedServletContextListener полезен для вызова метода shutdownExecutorService. Это гарантирует, что любые существующие задачи должны быть завершены до внезапного завершения работы приложения, но никакая новая задача не будет принята для обработки.

Answer 3

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

Среда на стороне сервера часто использует методы жизненного цикла, которые вы можете подключить, чтобы обнаруживать, когда ваш код отключается и полностью выходит из системы. Или вы можете использовать перехватчики выключения VM (возможно, чтобы отложить выключение до тех пор, пока все заданные в настоящее время задания не будут завершены), так что независимо от того, какой код заставляет программу выйти, будет запущен ваш код очистки.

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

Итак, простой ответ на ваш вопрос: «Когда он больше не будет использоваться». Почти в любом приложении есть точка, в которой это однозначно верно.

BTW, чтобы противоречить одному из других респондентов, ExecutorService может использовать потоки daemon - вы можете предоставить ThreadFactory, который настраивает потоки, но вы хотите, прежде чем запускать их. Но я бы посоветовал вам не использовать потоки демона и явно закрывать пул потоков в четко определенной точке - это не типичная практика, но это будет означать, что ваш код может быть полностью закрыт, и он будет побуждайте вас думать о жизненном цикле, что, вероятно, приведет к улучшению кода.

Answer 4

Однако я нашел, если только я не вызвал исполнителяService.shutdown(); приложение никогда не выходит,

Думаю, нам не нужно вызывать executorService.shutdown(); чтобы поддерживать приложение, верно?

Да. Приложение сохраняется, если вы не позвонили executorService.shutdown()

Каждое приложение должно иметь точку выхода. Вы можете вызвать выключение во время этой точки выхода.

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

В редких случаях виртуальная машина может прервать, то есть перестает работать без остановки чисто

Для примера вы процитировали, вы можете адресовать его несколько способов (invokeAll, Future.get(), CountDownLatch и др.). Посмотрите на соответствующий вопрос SE.

ExecutorService, how to wait for all tasks to finish