使用 CompletableFuture 检查异常 [重复]

Question

使用 Java 8 的强大功能 CompletableFuture，我想使用此新功能的异常来转换我的旧异步代码。但是检查的异常让我很困扰。这是我的代码。

CompletableFuture<Void> asyncTaskCompletableFuture = 
                CompletableFuture.supplyAsync(t -> processor.process(taskParam));

process方法的签名：

public void process(Message msg) throws MyException;

如何处理 ComletableFuture 中的检查异常？

Answer 1

这种方式我试过了，不知道是不是解决问题的好办法。

@FunctionalInterface
public interface RiskEngineFuncMessageProcessor<Void> extends Supplier<Void> {
    @Override
    default Void get() {
        try {
            return acceptThrows();
        } catch (final Exception e) {
            throw new RuntimeException(e);
        }
    }

    Void acceptThrows() throws Exception;

使用Supplier的FunctionalInterface，我可以包装异常：

final MyFuncProcessor<Void> func = () -> {
            processor.process(taskParam);
            return null;
        };

        CompletableFuture<Void> asyncTaskCompletableFuture =
                CompletableFuture.supplyAsync(func)
                        .thenAccept(act -> {
                            finishTask();
                        })
                        .exceptionally(exp -> {
                            log.error("Failed to consume task", exp);
                            failTask( exp.getMessage());
                            return null;
                        });