java - 使用 CompletionStage 而不是 CompletableFuture

Question

给出以下方法：

private static String getChuckNorrisJoke () {
    try {
        HttpURLConnection con = (HttpURLConnection) new
        URL( "http://api.icndb.com/jokes/random" ).openConnection();
        BufferedReader in = new BufferedReader( new InputStreamReader(con.getInputStream()));
        StringBuilder response = new StringBuilder();
        String line;
        while ((line = in.readLine()) != null ) {
            response.append(line);
        }
        in.close();
        return response.toString();
    } catch (IOException e) {
        throw new IllegalStateException( "Something is wrong: " , e);
    }
}

以下语句可用于以异步方式运行该方法。

final CompletableFuture<String> jokeAsync = CompletableFuture.supplyAsync(() -> getChuckNorrisJoke());

尽管我认为我了解CompletionStage与 的关系CompletableFuture，但我不确定如何使用它CompletionStage来完成相同的任务。

final CompletionStage<String> jokeAsync = ?

另外，我不确定“组合阶段”

Answer 1

CompletionStage是由 实现的接口CompletableFuture，因此您可以声明jokeAsync为 aCompletionStage并且它将起作用：

final CompletionStage<String> jokeAsync = CompletableFuture.supplyAsync(() -> getChuckNorrisJoke());

如果您有多个阶段，则可以以不同的方式组合它们，例如：

• thenCombine()结合2个阶段的结果
• applyToEither()处理第一个完成的结果并返回带有结果的新阶段
• acceptEither()在不返回新结果的情况下使用其中任何一个的结果
• runAfterBoth()并runAfterEither()在两个或任一阶段完成后运行操作。

CompletionStageAPI 不提供某些仅由以下人员提供的操作CompletableFuture：

• 提交任务，例如supplyAsync()
• 将许多阶段与allOf()和结合起来anyOf()
• 以编程方式完成阶段或创建已完成的阶段
• 等待阶段的结果join()或get()

但是toCompletableFuture()允许转换任何阶段，从而弥合差距。