Что такое TaskExecutor в Spring и чем он отличается от ExecutorService?

TaskExecutor в Spring vs ExecutorService

TaskExecutor — это абстракция Spring Framework для выполнения задач асинхронно. Хотя он построен на базе ExecutorService, Spring добавляет удобство и интеграцию с экосистемой.

TaskExecutor - основы

public interface TaskExecutor {
    void execute(Runnable task);
}

Это очень простой интерфейс, который Spring использует повсеместно для асинхронной обработки.

Конфигурация TaskExecutor в Spring

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

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

@Service
public class EmailService {
    
    @Async("customExecutor")
    public void sendEmail(String email) {
        // Выполняется в отдельном потоке из пула
        System.out.println("Отправка письма: " + email);
        Thread.sleep(5000); // Долгая операция
    }
    
    @Async("customExecutor")
    public CompletableFuture<String> processFile(String filename) {
        // Можно вернуть результат через CompletableFuture
        return CompletableFuture.completedFuture("Обработано: " + filename);
    }
}

Различия между TaskExecutor и ExecutorService

1. Уровень абстракции

ExecutorService - Java стандарт:

ExecutorService executor = Executors.newFixedThreadPool(10);
executor.submit(() -> System.out.println("Задача"));
executor.shutdown();

TaskExecutor - Spring обёртка:

@Autowired
private TaskExecutor taskExecutor;

public void runTask() {
    taskExecutor.execute(() -> System.out.println("Задача"));
}

2. Интеграция с Spring

TaskExecutor тесно интегрирован с Spring:

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.initialize();
        return executor;
    }
    
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (ex, method, params) -> 
            System.err.println("Ошибка в " + method.getName());
    }
}

Это позволяет использовать @Async аннотацию без явного вызова executor.

3. Управление жизненным циклом

ExecutorService:

executor.shutdown();
if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
    executor.shutdownNow();
}

TaskExecutor (управляется Spring):

// Spring автоматически управляет жизненным циклом
// Вызывает destroy-method при выключении контекста
@Bean
public TaskExecutor taskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    // ...
    executor.initialize();
    return executor;
}

4. Типы реализаций

ExecutorService имеет фиксированный набор реализаций (FixedThreadPool, CachedThreadPool и т.д.).

Spring TaskExecutor предлагает гибкие реализации:

// ThreadPoolTaskExecutor - самая распространённая
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

// SyncTaskExecutor - синхронное выполнение (для тестов)
TaskExecutor syncExecutor = new SyncTaskExecutor();

// SimpleAsyncTaskExecutor - создаёт новый поток для каждой задачи
TaskExecutor simpleExecutor = new SimpleAsyncTaskExecutor();

// ConcurrentTaskExecutor - обёртка над ExecutorService
ExecutorService es = Executors.newFixedThreadPool(10);
TaskExecutor wrapper = new ConcurrentTaskExecutor(es);

5. Future и результаты

ExecutorService:

Future<String> future = executor.submit(() -> "Результат");
String result = future.get(); // Блокирующий вызов

TaskExecutor с CompletableFuture:

@Async("taskExecutor")
public CompletableFuture<String> getResult() {
    return CompletableFuture.completedFuture("Результат");
}

// Использование
service.getResult()
    .thenAccept(result -> System.out.println(result))
    .exceptionally(ex -> {
        System.err.println("Ошибка");
        return null;
    });

6. Обработка исключений

ExecutorService:

try {
    future.get();
} catch (ExecutionException e) {
    // Обработка исключения из задачи
}

Spring TaskExecutor:

@EnableAsync
@Configuration
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (throwable, method, params) -> {
            System.err.println("Ошибка в " + method.getName() + ": " + throwable);
        };
    }
}

Сравнительная таблица

Когда использовать

✅ TaskExecutor в Spring приложениях:

• Интеграция с @Async
• Нужна управляемость Spring'ом
• Требуется единая конфигурация

✅ ExecutorService для:

• Чистого Java без фреймворков
• Точного контроля над жизненным циклом
• Более явного кода

Выводы: TaskExecutor — это удобная Spring-абстракция над ExecutorService, обеспечивающая лучшую интеграцию и управление в контексте Spring приложений.