Konfigurieren von ThreadPoolTaskExecutor mit benutzerdefinierten Ablehnungsrichtlinien

@Configuration
@EnableAsync
public class AsyncExecutionConfig {
 
    @Bean(name = "eventProcessingExecutor")
    public Executor eventProcessingExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(4);
        executor.setMaxPoolSize(16);
        executor.setQueueCapacity(50);
        executor.setThreadNamePrefix("EventWorker-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.setWaitForTasksToCompleteOnShutdown(true);
        executor.setAwaitTerminationSeconds(30);
        executor.initialize();
        return executor;
    }
}
 
@Service
public class EventPublisher {
 
    @Async("eventProcessingExecutor")
    public CompletableFuture<String> processEventPayload(String eventId) {
        return CompletableFuture.completedFuture("Processed: " + eventId);
    }
}