Scala中序列中的多个期货

Question

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

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

我希望它能够运行，以便comp2总是在comp1完成后运行！我知道使用一个表达，我可以组成这两个Future的喜欢。

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

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

Answer 1

用于理解的 Scala 是用于“容器类型”（在本例中为 Futures）的 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(例如< code>val comp2 = () =

  comp2Result <- comp2()

里面的理解。