Какие знаешь особенности создания ExecutorService в Spring?

ExecutorService в Spring

ExecutorService — ключевой компонент для управления потоками и асинхронными операциями в Spring приложениях. Это часть java.util.concurrent и Spring предоставляет удобные способы его конфигурации и использования.

Основные способы создания ExecutorService

1. Через ThreadPoolTaskExecutor (рекомендуется)

Это Spring-адаптер над ExecutorService, который интегрируется с контекстом приложения:

@Configuration
public class ExecutorConfig {
    @Bean(name = "taskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("async-");
        executor.initialize();
        return executor;
    }
}

Преимущества:

• Наследует TaskExecutor интерфейс Spring
• Автоматически управляется контекстом
• Поддерживает graceful shutdown
• Интегрируется с @Async аннотацией

2. Через Executors factory методы

@Bean
public ExecutorService executorService() {
    return Executors.newFixedThreadPool(10);
}

Вариации:

• newFixedThreadPool(n) — n потоков, неограниченная очередь
• newCachedThreadPool() — динамическое количество потоков (60 сек timeout)
• newSingleThreadExecutor() — один поток, сохраняет порядок
• newScheduledThreadPool(n) — для задач по расписанию

3. Через ThreadPoolExecutor (максимальный контроль)

@Bean
public ExecutorService executorService() {
    return new ThreadPoolExecutor(
        5,           // corePoolSize
        10,          // maximumPoolSize
        60,          // keepAliveTime
        TimeUnit.SECONDS,
        new LinkedBlockingQueue<>(100),
        new ThreadFactory() {
            private int count = 0;
            @Override
            public Thread newThread(Runnable r) {
                Thread t = new Thread(r);
                t.setName("custom-thread-" + count++);
                return t;
            }
        },
        new ThreadPoolExecutor.CallerRunsPolicy()  // RejectedExecutionHandler
    );
}

Важные параметры

Использование @Async

Spring автоматически использует ExecutorService аннотированный как taskExecutor:

@Service
public class UserService {
    @Async("taskExecutor")
    public CompletableFuture<String> sendEmailAsync(String email) {
        // Выполняется в отдельном потоке
        return CompletableFuture.completedFuture("Email sent");
    }
}

Правильное завершение работы

@Bean
public ExecutorService executorService() {
    ExecutorService executor = Executors.newFixedThreadPool(5);
    
    // Graceful shutdown при остановке приложения
    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
        executor.shutdown();
        try {
            if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
        }
    }));
    
    return executor;
}

Или через@PreDestroy в конфигурации.

Ключевые особенности

• ThreadPoolTaskExecutor — лучший выбор для Spring приложений
• Размер пула зависит от типа задач (CPU-bound vs I/O-bound)
• Всегда явно указывай имена потоков для логирования
• Используй CompletableFuture или ListenableFuture для обработки результатов
• Не забывай о graceful shutdown — это критично для production
• Мониторь метрики очереди и отклоненных задач