Что такое ExecutorService в Java?

ExecutorService — это высокоуровневая альтернатива ручному управлению потоками. Он предоставляет средства для управления пулом потоков и отправки на выполнение задач (реализующих Runnable или Callable). Это упрощает асинхронное выполнение задач, обработку жизненного цикла потоков и управление их количеством, избегая создания нового потока для каждой отдельной задачи, что неэффективно.

Основные преимущества:

• Управление жизненным циклом потоков: ExecutorService берет на себя создание, запуск и остановку потоков.
• Количество потоков: Позволяет настроить фиксированное или динамическое количество потоков в пуле.
• Очередь задач: Задачи, которые не могут быть выполнены немедленно из-за ограниченного количества потока пула, помещаются в очередь.
• Обработка результатов: Можно получить результаты выполнения задач с помощью Future.

Интерфейсы и классы:

• Executor: Базовый интерфейс, который предоставляет метод execute(Runnable).
• ExecutorService: Расширяет Executor, добавляя методы для управления жизненным циклом пула (shutdown(), awaitTermination()) и приема задач, возвращающих результат (submit(Callable), submit(Runnable, T), invokeAll, invokeAny).
• ScheduledExecutorService: Расширяет ExecutorService, добавляя функциональность для планирования выполнения задач с задержкой или по расписанию.
• Executors: Вспомогательный класс, предоставляющий фабричные методы для создания стандартных реализаций ExecutorService.

Пример создания и использования:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

// Создаем пул потоков с фиксированным количеством потоков
ExecutorService executor = Executors.newFixedThreadPool(5);

// Отправляем задачу на выполнение
executor.execute(() -> {
    // Код, выполняющийся в отдельном потоке
    System.out.println("Задача выполняется в потоке: " + Thread.currentThread().getName());
});

// Другой способ отправки задачи, возвращающей результат (не показано в этом примере)
// Future<?> future = executor.submit(() -> { ... });

// Завершаем работу ExecutorService
executor.shutdown();

// Ожидаем завершения всех задач в пуле (опционально)
try {
    executor.awaitTermination(60, TimeUnit.SECONDS);
} catch (InterruptedException e) {
    e.printStackTrace();
}

System.out.println("ExecutorService завершил работу.");