Java ExecutorService to interfejs, który umożliwia asynchroniczne wykonywanie zadań w wątkach. Interfejs Java ExecutorService znajduje się w pakiecie java.util.concurrent. ExecutorService pomaga w utrzymaniu puli wątków i przydziela im zadania. Zapewnia także możliwość ustawiania zadań w kolejce do momentu udostępnienia wolnego wątku, jeśli liczba zadań przekracza liczbę dostępnych wątków.

Metody Java ExecutorService

Prosty program Java ExecutorService

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newFixedThreadPool(10); executorService.execute(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); executorService.shutdown(); } } 

Wyjście:

W tym programie tworzymy usługę ExecutorService z dziesięcioma wątkami i przypisujemy jej anonimową, uruchamialną implementację, która wykonuje zadanie wydrukowania usługi ExecutorService, a po zakończeniu tego zadania zamykamy usługę executora.

Jak korzystać z usługi Java ExecutorService

Tworzenie instancji usługi ExecutorService

Możemy użyć Java ExecutorService do utworzenia pojedynczego wątku, puli wątków lub zaplanowanej puli wątków. Klasa Executors udostępnia metody fabryczne umożliwiające utworzenie instancji ExecutorService w następujący sposób:

 ExecutorService executorService1 = Executors.newSingleThreadExecutor(); //Creates //a ExecutorService object having a single thread. ExecutorService executorService2 = Executors.newFixedThreadPool(10); // Creates a //ExecutorService object having a pool of 10 threads. ExecutorService executorService3 = Executors.newScheduledThreadPool(10); //Creates a scheduled thread pool executor with 10 threads. In scheduled thread //pool, we can schedule tasks of the threads. 

Przypisywanie zadań do ExecutorServices

Aby przypisać zadanie do ExecutorService, możemy skorzystać z następujących metod:

• wykonaj (zadanie możliwe do uruchomienia)
• przesłać (zadanie możliwe do wykonania) / przesłać (zadanie możliwe do wywołania)
• invokeAny(Kolekcjazadania)
• invokeAll (kolekcjazadania)

Przykład przypisania zadania do ExecutorService przy pomocy metody generate().

Metoda ExecutorService Java ExecutorService pobiera uruchamialny obiekt i wykonuje swoje zadanie asynchronicznie. Po wywołaniu metody wykonywania wywołujemy metodę zamykania, która blokuje umieszczenie w kolejce wszelkich innych zadań w usłudze executorService.

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newSingleThreadExecutor(); executorService.execute(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); executorService.shutdown(); } } 

Wyjście:

 ExecutorService 

Przykład przypisania zadania do ExecutorService za pomocą metody Submit()

Metoda Submit() pobiera obiekt możliwy do uruchomienia i zwraca obiekt Future. Obiekt ten jest później używany do sprawdzania statusu Runnable, czy zakończył on wykonywanie, czy nie.

 public class ExecutorServiceExample { public static void main(String[] args) { ExecutorService executorService = Executors.newSingleThreadExecutor(); executorService.submit(new Runnable() { @Override public void run() { System.out.println('ExecutorService'); } }); } } 

Przykład przypisania zadania do ExecutorService metodą invokeAny().

Metoda invokeAny() pobiera kolekcję obiektów Callablle lub obiektów klas implementujących Callable. Ta metoda zwraca przyszły obiekt wywoływalnego obiektu, który zostanie pomyślnie wykonany jako pierwszy.

znowu skorupa Bourne’a

 public class ExecutorServiceExample { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executorService = Executors.newSingleThreadExecutor(); Set<callable> callables = new HashSet<callable>(); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 1&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 2&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 3&apos;; } }); String result = executorService.invokeAny(callables); System.out.println(&apos;result = &apos; + result); executorService.shutdown(); } } </callable></callable>

Wyjście:

 result = Task 1 

Wynik przechowuje zadanie 1, ponieważ pierwszy możliwy do wywołania obiekt został pomyślnie wykonany jako pierwszy.

Przykład przypisania zadania do ExecutorService metodą invokeAll().

Metoda invokeAll() pobiera kolekcję obiektów Callable zawierających zadania i zwraca listę obiektów Future zawierających wyniki wszystkich zadań.

 public class ExecutorServiceExample { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executorService = Executors.newSingleThreadExecutor(); Set<callable> callables = new HashSet<callable>(); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 1&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 2&apos;; } }); callables.add(new Callable() { public String call() throws Exception { return &apos;Task 3&apos;; } }); java.util.List<future> futures = executorService.invokeAll(callables); for(Future future : futures){ System.out.println(&apos;future.get = &apos; + future.get()); } executorService.shutdown(); } } </future></callable></callable>

Wyjście:

 future.get = Task 1 future.get = Task 3 future.get = Task 2 

Jak zamknąć usługę ExecutorService

Kiedy już skończymy zadania powierzone ExecutorService, musimy je zamknąć, ponieważ ExecutorService wykonuje zadanie w różnych wątkach. Jeśli nie zamkniemy usługi ExecutorService, wątki będą nadal działać, a maszyna JVM nie zostanie zamknięta.

Proces zamykania można wykonać trzema następującymi metodami:

• metoda zamknięcia().
• metoda ShutdownNow().
• metoda waitTermination().