涉及提前返回时将阻塞代码转换为非阻塞代码

Question

我正在尝试转换如下所示的阻塞 Play 框架控制器操作：

public Result testSync(String param1, String param2) {

    String result1 = <LONG-DB-QUERY>;
    if (result1 == null) {
        return internalServerError();
    }

    if (result1.equals("<SOME VALUE>")) {
        return ok(param1);
    }

    String result2 = <LONG-DB-QUERY>;
    return ok(result1 + result2);
}

使用Future接口进入非阻塞代码，即返回一个CompletionStage<Result>

如您所见，我需要result1 和result2。我假设我不能使用supplyAsync 和thenCombine，因为result2 只有在某些情况下才需要计算。

Answer 1

好的，基于similar answer，我就是这样做的：

public CompletionStage<Result> testAsync(String param1, String param2) {

    CompletableFuture<Result> shortCut = new CompletableFuture<>();
    CompletableFuture<String> withChain = new CompletableFuture<>();

    CompletableFuture.runAsync(() -> {
        String result1 = <LONG-DB-QUERY>;
        if (result1 == null) {
            shortCut.complete(internalServerError());
            return;
        }

        if (result1.equals("<SOME VALUE>")) {
            shortCut.complete(ok(param1));
            return;
        }

        withChain.complete(result1);
    });

    return withChain
            .thenCombine(CompletableFuture.supplyAsync(() -> <LONG-DB-QUERY>), (newParam1, newParam2) -> ok(result1+result2))
            .applyToEither(shortCut, Function.identity());
}