自定义ThreadPoolTaskExecutor搭配@Async使用时Future.get()抛NPE问题求助

问题根因 #

出现该NPE问题的核心原因是两种异步注解的切面优先级冲突，以及返回值类型适配不匹配：

1. 你在替换Hystrix异步实现时，没有移除方法上的@HystrixCommand注解，Hystrix切面的默认执行优先级高于Spring @Async注解的切面优先级，导致方法调用时先进入Hystrix切面逻辑，直接调用原始方法的返回值，没有走@Async的代理包装逻辑，最终返回的Future对象为空，调用get()时触发NPE。
2. 自定义线程池场景下，Spring @Async对CompletableFuture类型的返回值适配逻辑更完善，声明为父类Future时部分版本的Spring会出现返回值包装失败的问题。

解决方案 #

步骤1：移除冲突注解 #

如果要完全替换Hystrix的异步实现，直接去掉方法上的@HystrixCommand注解即可。如果需要保留熔断降级能力，建议改用原生支持CompletableFuture的Resilience4j组件替代已停止维护的Netflix Hystrix。

步骤2：修正异步方法返回值声明 #

将方法返回值从Future<MyResponse>显式改为CompletableFuture<MyResponse>，适配Spring的异步返回值处理逻辑：

@Async("myExecutor")
public CompletableFuture<MyResponse> computationTaskAsync(){
    MyResponse response = downStreamConnector.getProducts(); 
    return CompletableFuture.completedFuture(response);
}

步骤3：优化自定义线程池配置 #

调整Executor的返回类型为ThreadPoolTaskExecutor，同时补充拒绝策略避免任务异常被吞：

@Configuration
@EnableAsync // 若未添加该注解请补充，开启Spring异步能力
public class AsyncConfig {
    @Bean("myExecutor")
    public ThreadPoolTaskExecutor myExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(200);
        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("myExecutor-");
        // 自定义拒绝策略，队列满时由调用线程执行任务，可根据业务需求调整为其他策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

步骤4：确认调用逻辑 #

必须通过Spring注入的Bean实例调用该异步方法，禁止在方法所在类内部直接调用（未走代理会导致@Async注解失效）。

内容的提问来源于stack exchange，提问作者uuid