如何在CompletableFuture中访问前一阶段的结果

Question

我正在尝试将任务链接到CompletableFuture中，以并行执行它们并获得最佳性能和资源利用率。

我正在编写的工作流有五个阶段，每个阶段取决于前几个阶段的结果。

工作流执行如下:

* Stage-1: Create CustomerContext -> This will call downstream services and return Context object.
    
* Stage-2: Generate Candidates for the customer -> This stage generate candidates and returns a List<Candidate> object. This stage requires CustomerContext as a parameter to generate the candidates. 
    
* Stage-3: Process Candidate -> In this stage I process the candidates and returns processed List<Candidate>. This stage requires CustomerContext and List<Candidate> object from stage-1 and stage-2 
    
* Stage-4: Rank candidates -> In this stage I perform candidate ranking and returns ranked List<Candidate> object. This stage requires CustomerContext and List<Candidate> object from stage-1 and **stage-3** 
      
* Stage-5: Generate Result -> In this stage I generate the final result and returns Result object by making downstream API calls., This stage requires CustomerContext and List<Candidate> object from **stage-1** and **stage-4** 

我可以创建一个结果持有器对象来保存每个阶段的结果。但是，我不确定这是否是最好的解决方案。

CompletableFuture是此用例的最佳解决方案吗？链接这些阶段的最佳方式是什么？

Answer 1

使用thenCompose组合来自相互依赖的不同期货的结果：

CompletableFuture<String> result =
    CompletableFuture.supplyAsync(() -> "result 1")
        .thenCompose(result1 ->
    CompletableFuture.supplyAsync(result1::length)
        .thenCompose(strLen ->
    CompletableFuture.supplyAsync(strLen::toString)));

但请注意，由于每个未来都依赖于前一个未来的结果，因此无法并行执行它们。每个未来仍将在上一个完成后执行。如果期货不相互依赖，您可以通过“挖掘隐藏的应用”来并行运行它们。

还要注意的是，CompletableFuture只有supplyAsync、runAsync分别接受供应商、可运行，并且没有直接方法处理可能引发异常的异步操作（例如运行可调用）。如果您需要这样做，您必须按照本答案中的描述，将其委托给未来的助手。