时间戳

首页 > 解决方案 > 如何抽象捕获异常 CompletableFutures 以调用方法

java - 如何抽象捕获异常 CompletableFutures 以调用方法

问题描述

好的，我有类似的方法

  1. CompletableFuture fetchCar(int id);
  2. CompletableFuture runSomething(Something t, Extra d);
  3. CompletableFuture 调用（）；

并且我想要一个可以使用的方法来执行以下操作，以便将任何同步异常转换为将来放置

private CompletableFuture<Void> invokeSomething(Something something) {
    CompletableFuture<Void> future;
    try {
        future = something.runSomething(t, d);
    } catch(Throwable e) {
        future = new CompletableFuture<Void>();
        future.completeExceptionally(e);
    }

    return future;
}

请注意，我只是碰巧选择了 #2 作为示例，但我想让它变得通用，这样我就可以停止输入它，因为通常它需要不时完成，以确保您处理同步和异步异常相同。

标签： javacompletable-future

解决方案

我不确定这是你要找的，但你可以创建一个实用函数：

public static <T> CompletableFuture<T> foo(Callable<CompletableFuture<T>> callable) {
    try {
        return callable.call();
    } catch (Exception ex) {
        return CompletableFuture.failedFuture(ex);
    }
}

然后你会像这样使用它：

Something something = ...;
CompletableFuture<Void> future = foo(() -> invokeSomthing(something));

一些注意事项：

  1. 使用Callable它是因为它的函数方法call, 可以抛出Exception. 如果使用类似的东西Supplier，那么将它与可以抛出检查异常的方法一起使用会很混乱。
  2. 使用catch (Exception ex)而不是catch (Throwable ex)因为Callable#call不抛出Throwable，通常认为捕获Errors 是不好的做法。如果需要，您可以随时将其更改为Throwable。
  3. 这个实用方法将返回一个失败的未来，由 NPE 引起，如果callable是null; 不知道这是否需要。

推荐阅读