Scala中序列中的多个期货

Question

我有两个在 Future 中发生的计算，如下所示：

val comp1 = Future { ... }
val comp2 = Future { ... }

我希望它运行，以便 comp2 始终在 comp1 完成后运行！我知道使用 for 表达式，我可以组成这两个 Future 的like。

for {
  comp1Result <- comp1
  comp2Result <- comp2
} yield { ... }

comp1 在 comp2 之前完成的保证是什么？我的意思是这些是在不同线程中发生的计算，并且不能保证它可能运行的顺序。有没有办法保证订单不阻塞？

Answer 1

用于理解的 Scala 是 flatMap 和 map 对“容器类型”（在本例中为期货）调用组合的语法糖，因此您上面的代码等同于：

comp1.flatMap{ comp1Result => comp2 }

这里的大括号内的计算只有在comp1完成并返回成功的结果后才会发生（失败的情况下，内部的计算不会被执行）。

如果您在 for 理解之外定义 comp2 如问题所示，那么您将开始该计算（您只需忽略结果，直到您在 for 理解中），但如果您仅在 for 中定义它理解，那么它不会被启动，除非且直到 comp1 成功完成。因此，请尝试按如下方式重新调整代码：

val comp1 = Future { ... } // or you could put this construction inside the for as well
for {
  comp1Result <- comp1
  comp2Result <- Future { ... } // Only start the computation here
  comp3Result <- Future { ... } // etc. for as many such computations as you need
} yield { ... }

其他替代方法是将 comp2 声明为惰性 val（因此实际上不会对其进行评估 - 开始计算 - 直到它被引用），或者声明为 lambda（例如 val comp2 = () => Future { ... }）并使用以下行调用它

  comp2Result <- comp2()

在 for 理解中。