如何连锁完成期货

Question

现在，我有三个函数：updateFieldFromCollection1（）、InsertFromCollection1ToCollection2（）和deleteFromCollection1（）。

这些调用并不是相互依赖的，但是当我想将它们完全链接到Future时，它们必须按照给定的顺序一个接一个地运行。

update-> insert -> delete

这些调用不会返回任何结果，所以我使用了runAsync和completableFuture的run方法。并相应地把他们锁起来。我在msgIds上迭代，它是一个字符串列表。

msgIds.stream().forEach(msgId -> CompletableFuture.runAsync(() ->  
 {updateFieldFromCollection1()}).thenRun(() -> 
 {insertFromColletion1ToCollection2()}).thenRun(() ->  
 {deleteFromCollection1()}));

以上代码有效（更新-




Answer 1

msgIds.stream().forEach(msgId -> {
updateFieldFromCollection1();
 CompletableFuture.runAsync(() -> 
 {insertFromColletion1ToCollection2()}).thenRun(() ->  
 {deleteFromCollection1()}));

更新必须在completableFuture之外进行。然后它就像一个符咒：）