使用CompletableFuture链的Java中断执行序列

Question

我是Java的新手，正在使用CompletableFutures执行异步操作，如下所示：

java prettyprint-override">public CompletionStage<Either<ErrorResponse, Response>> insertOrUpdate(String actor, String key) {
    return this.objectDAO.getByKey(key)
            .thenApply(mapDOToContainer(key))
            .thenApply(mergeContainerToDO(key, actor))
            .thenComposeAsync(this.objectDAO.UpdateFn())
            .thenApply(DBResult::finished)
            .thenApply(finished -> {
                if (finished) {
                    Response response = Response.ok().build();
                    return Either.right(response);
                } else {
                    return Either.left(ErrorResponse.create("Error", 400));
                }
            });
}

现在我需要修改它，这样，如果get失败，我就执行上面的链，但是如果成功，我就需要打破这个链，从函数返回一个包含ErrorResponse的任一对象。

如何才能打破这个加工链条？我知道我可以向链中的每个函数传递一个标志，并通过根据标志的值执行函数中的操作来实现这一点。我希望有更好的办法。

谢谢！！

Answer 1

我会重写你的代码。

• 对于错误都不要使用，Java有异常
• 不从DAO返回CompletionStage
• 例外使用来自CompletableFuture,它就是为此而设计的

然后执行以下操作：

public CompletionStage<Response> insertOrUpdate(String actor, String key) {
    return CompletableFuture.supplyAsync(() -> this.objectDAO.getByKey(key))
            .thenApply(mapDOToContainer(key))
            .thenApply(mergeContainerToDO(key, actor))
            .thenComposeAsync(this.objectDAO.UpdateFn())
            .thenApply(DBResult::finished)
            .thenApply(finished -> {
                Response response = Response.ok().build();
                return response;
            })
            .exceptionally(e -> ErrorResponse.create("Error", 400));
}

DAO应该是这样的：

class ObjectDAO {
    public Object getByKey(String key) {
        if (keyNotFound) {
            throw new NoSuchElementException();
        }

        return new Object();
    }
}

您可能必须确保ErrorResponse是Response的子类才能使其工作。