Java ExecutorService — це інтерфейс, який дозволяє асинхронно виконувати завдання в потоках. Інтерфейс Java ExecutorService присутній у пакеті java.util.concurrent. ExecutorService допомагає підтримувати пул потоків і призначає їм завдання. Він також надає можливість ставити завдання в чергу, доки не буде доступний вільний потік, якщо кількість завдань перевищує кількість доступних потоків.

Методи Java ExecutorService

Проста програма 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(); } } 

Вихід:

У цій програмі ми створюємо ExecutorService з десятьма потоками та призначаємо йому анонімну виконувану реалізацію, яка виконує завдання друку «ExecutorService», а після завершення цього завдання ми вимикаємо службу виконавця.

Як використовувати Java ExecutorService

Створення екземпляра ExecutorService

Ми можемо використовувати Java ExecutorService для створення окремого потоку, пулу потоків або запланованого пулу потоків. Клас Executors надає фабричні методи для створення екземпляра ExecutorService наступним чином:

git додати все

 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. 

Призначення завдань ExecutorServices

Щоб призначити завдання ExecutorService, ми можемо використати такі методи:

• виконати (виконуване завдання)
• submit(Runnable task) / submit(Callable task)
• invokeAny(Колекціязавдання)
• invokeAll(Колекціязавдання)

Приклад призначення завдання ExecutorService за допомогою методу execute().

Метод execute() Java ExecutorService приймає запущений об’єкт і виконує його завдання асинхронно. Після виклику методу execute ми викликаємо метод shutdown, який блокує будь-яке інше завдання в черзі в 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(); } } 

Вихід:

 ExecutorService 

Приклад призначення завдання ExecutorService за допомогою submit()

Метод submit() приймає об’єкт, що виконується, і повертає об’єкт Future. Пізніше цей об’єкт використовується для перевірки статусу Runnable, чи завершено його виконання чи ні.

 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'); } }); } } 

Приклад призначення завдання ExecutorService за допомогою методу invokeAny().

10 відсотків від 60

Метод invokeAny() приймає колекцію об’єктів Callablle або об’єктів класів, що реалізують Callable. Цей метод повертає майбутній об’єкт викликаного об’єкта, який успішно виконується першим.

 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>

Вихід:

 result = Task 1 

Результат зберігає Завдання 1, оскільки перший успішно виконаний об’єкт, який можна викликати.

Приклад призначення завдання ExecutorService за допомогою методу invokeAll().

Метод invokeAll() приймає колекцію викликаних об’єктів із завданнями та повертає список майбутніх об’єктів із результатом усіх завдань.

 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>

Вихід:

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

Як вимкнути ExecutorService

Коли ми виконаємо завдання, передані ExecutorService, ми повинні вимкнути його, оскільки ExecutorService виконує завдання в різних потоках. Якщо ми не вимкнемо ExecutorService, потоки продовжуватимуть працювати, а JVM не вимкнеться.

Процес вимкнення можна виконати трьома способами:

• метод shutdown().
• метод shutdownNow().
• метод awaitTermination().