Scala Futures 如何与 flatMap 链接在一起？

我正在 Scala 中首次使用 Futures，并且正在研究使用 flatMap 组合器的示例；我一直在关注这个讨论：

http://docs.scala-lang.org/overviews/core/futures.html http://docs.scala-lang.org/overviews/core/futures.html

具体来说，这个例子：

val usdQuote = future { connection.getCurrentValue(USD) }
val chfQuote = future { connection.getCurrentValue(CHF) }
val purchase = for {
    usd <- usdQuote
    chf <- chfQuote
      if isProfitable(usd, chf)
} yield connection.buy(amount, chf)

purchase onSuccess {
    case _ => println("Purchased " + amount + " CHF")
}

翻译成这样：

val purchase = usdQuote flatMap {
    usd =>
         chfQuote
        .withFilter(chf => isProfitable(usd, chf))
        .map(chf => connection.buy(amount, chf))
}

我有点难以理解的是 flatMap 是如何以及何时执行的？

我知道 usdQuote 和 chfQuote 是由“某个线程”在“某个时间”执行的，并且它们注册的回调函数被调用，问题是：

a) usdQuote 和 chfQuote 是否同时执行？ （我很确定他们是）。

b) flatMap如何将Future useQuote的值赋给usd？例如，当操作 usdQuote 完成时它会被调用吗？

c) 哪个线程正在执行“flatMap”和“map”操作（可能更多是上一个问题的后续）。

Cheers.

• a) 当您创建它们时，您已经开始在范围内针对隐式 ExecutionContext 执行它们，因此它们可能会同时运行，因为这取决于它们的执行方式。

• b) 它并没有真正分配值，但实现使用 onComplete 方法来导致您传递的函数在达到结果后被触发。目前，这应该链接到我所指的 flatMap 方法：https://github.com/scala/scala/blob/v2.11.2/src/library/scala/concurrent/Future.scala#L246 https://github.com/scala/scala/blob/v2.11.2/src/library/scala/concurrent/Future.scala#L246

• c) 这些是通过前面提到的 ExecutionContext 运行的，还要考虑一下，如果这些 Future 实例可以在不同的 ExecutionContext 上运行，那么 for 理解的部分可以在不同的线程池上运行。