Как работают Executor в Java?

Executor — это интерфейс в Java, который определяет контракт для выполнения задач в пуле потоков. Вместо явного создания потоков для каждой задачи, вы передаете задачи исполнителям, а они управляют созданием, использованием и уничтожением потоков.

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

• Управление потоками: Предоставляет единый способ управления пулом потоков, избавляя от ручного создания и синхронизации потоков.
• Эффективность: Повторно использует существующие потоки, снижая накладные расходы на создание и уничтожение потоков.
• Производительность: Улучшает производительность и отзывчивость приложений за счет асинхронного выполнения задач.

Executor имеет один метод:

// Выполняет данную команду в какое-то время в будущем.
void execute(Runnable command);

Часто используются подтипы:

• ExecutorService: Расширяет Executor и предоставляет дополнительные методы для управления жизненным циклом исполнителя и получения результатов выполнения задач (например, через Future).
• ScheduledExecutorService: Расширяет ExecutorService и позволяет выполнять задачи с задержкой или по расписанию.

Класс Executors предоставляет фабричные методы для создания различных типов исполнителей:

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

// Создает пул потоков, который может динамически регулировать количество потоков.
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// Создает пул потоков, который может выполнять задачи по расписанию.
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

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

// Объект исполнителя
ExecutorService executor = Executors.newFixedThreadPool(2);

// Задача для выполнения
Runnable task = new Runnable() {
    @Override
    public void run() {
        // Код задачи
        System.out.println("Выполняется задача в потоке: " + Thread.currentThread().getName());
    }
};

// Передача задачи исполнителю
executor.execute(task);

// Завершение работы исполнителя (необходимо для освобождения ресурсов)
executor.shutdown();

При вызове execute(), исполнитель берет задачу (Runnable) и передает ее одному из потоков в своем пуле для выполнения. Управление распределением задач между потоками и их жизненным циклом берет на себя исполнитель.