在条件函数中返回 CompletableFuture<Void>

Question

我有一个用例，我必须从一个基于条件组成 2 个 Completable Futures 的函数返回一个 CompletableFuture<Void>。

以下是我现在拥有的 -

private CompletableFuture<Void> processSomething(final SomeEvent event) {
    final CompletableFuture<PaginatedQueryList<Detail>> detail = dao.getData(event.getOrderId());
    return detail.thenApply(n -> n.stream()
        .filter(i -> i.getBusinessType().equals(BusinessType.AWESOME))
        .findFirst()
        .filter(i -> i.getLastUpdateEventTimestamp() <= event.getCreationTime())) // This returns Optional<Detail>
        .thenCompose(i -> i
           .map(o -> deleteItem(event,o))
           .orElse(CompletableFuture.completedFuture(null))); // deleteItem is a async call that returns CompletableFuture<Void>
}

社区可以检查并建议任何其他方法吗？
我特别不喜欢明确返回CompletableFuture.completedFuture(null)。

Answer 1

在thenCompose 的函数中返回已经完成的未来并没有错。正如this answer 中提到的，您还可以使用CompletableFuture.allOf() 来表示一个空的任务列表，以达到相同的结果。

但您可以使用.orElseGet(() -> …) 来避免提前构建已完成的未来，即使在不需要时也是如此。

此外，您可以将thenApply(…).thenCompose(…) 链替换为单个thenCompose(…)：

private CompletableFuture<Void> processSomething(final SomeEvent event) {
    CompletableFuture<PaginatedQueryList<Detail>> detail = dao.getData(event.getOrderId());
    return detail.thenCompose(n -> n.stream()
        .filter(i -> i.getBusinessType().equals(BusinessType.AWESOME))
        .findFirst()
        .filter(i -> i.getLastUpdateEventTimestamp() <= event.getCreationTime())
        .map(o -> deleteItem(event, o))
        .orElseGet(() -> CompletableFuture.completedFuture(null)));
// or   .orElseGet(() -> CompletableFuture.allOf()));
// or   .orElseGet(CompletableFuture::allOf));

}

Answer 2

实现它的方法之一是，只需进行两项更改。

1. 将Optional<Detail> 作为参数传递给delete 方法并生成 在执行实际逻辑之前对其进行必要的检查。
2. 将.thenCompose() 更改为.thenAccept()。它会回来 CompletionStage<Void> 您可以将其转换为 CompletableFuture<Void> 在方法返回的顶部返回之前。

---

private CompletableFuture<Void> processSomething(final SomeEvent event) {
    final CompletableFuture<PaginatedQueryList<Detail>> detail = dao.getData(event.getOrderId());
    return (CompletableFuture<Void>)detail.thenApply(n -> n.stream()
        .filter(i -> i.getBusinessType().equals(BusinessType.AWESOME))
        .findFirst()
        .filter(i -> i.getLastUpdateEventTimestamp() <= event.getCreationTime())) // This returns Optional<Detail>
        .thenAccept(i -> deleteItem(event, i).join())); // deleteItem is a async call that returns CompletableFuture<Void>
}

private CompletableFuture<Void> deleteItem(Optional<Detail> optionalDetail){
     if(optionalDetail.isPresent()){
       // Your existing logic
     }
}

假设如果您不想更改deleteItem() 方法签名，那么只需这样做，

.thenAccept(i -> 
     {
      if(i.isPresent()){
         deleteItem(event, i.get());
      }
     });