CompletatbleFuture与Spring的Async一起使用时的异常处理

Question

我对这个可完成的未来概念很陌生。我使用Spring的异步注释，为此我为执行器和异常处理程序添加了一个文件配置，如下所示:

@Override
public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(CORE_POOL_SIZE);
    taskExecutor.setMaxPoolSize(MAX_POOL_SIZE);
    taskExecutor.setQueueCapacity(QUEUE_CAPACITY);
    taskExecutor.setThreadNamePrefix("AsyncThread - ");
    taskExecutor.initialize();
    return taskExecutor;
}

@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    return asyncExceptionHandler;
}

然后我有一个方法，我想异步运行并返回CompletableFuture：

@Async
public CompletableFuture<Void someMethod() {
     try {
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return CompletableFuture.completedFuture(null);
}

现在，如果在上述方法调用中发生了一些异常，那么我应该如何处理该异常？

注意：如果我不返回CompletableFuture并返回vo，它将转到异常处理程序AsyncUncaughtExceptionHandler，但根据我的要求，我想返回CompletableFuture Void。

Answer 1

这是预期的行为。查看AsyncExecutionAspectSupport类方法handleError：

protected void handleError(Throwable ex, Method method, Object... params) throws Exception {
    if (Future.class.isAssignableFrom(method.getReturnType())) {
        ReflectionUtils.rethrowException(ex);
    }
    else {
        // Could not transmit the exception to the caller with default executor
        try {
            this.exceptionHandler.obtain().handleUncaughtException(ex, method, params);
        }
        catch (Throwable ex2) {
            logger.warn("Exception handler for async method '" + method.toGenericString() +
                    "' threw unexpected exception itself", ex2);
        }
    }
} 

如果方法返回类型是Future的变体，则始终If（Future.class.isAssignableFrom（method.getReturnType（）），其计算结果为true，并且异常被重新抛出，由更高级别的调用方处理，因此它不由AsyncUncaughtExceptionHandler处理。

您可以通过CompletableFuture提供的工具来处理异常，例如handle（双功能