scala - Akka future - 并行与并发？

Question

来自写得很好的Akka Concurrency :

据我了解，该图指出，numSummer 和 charConcat 将在同一线程上运行。

是否可以并行运行每个Future，即在单独的线程上？

Answer 1

左边的图片是它们并行运行。

插图的要点是 Future.apply 方法是启动执行的方法，因此如果直到第一个 future 的结果为 flatMap 时才发生ed(如右图所示)，那么你就得不到并行执行。

(请注意，“启动”是指相关的 ExecutionContext 被告知有关该作业的信息。它如何并行化是一个不同的问题，可能取决于诸如其线程池的大小。)

左侧的等效代码:

val numSummer = Future { ... }  // execution kicked off
val charConcat = Future { ... }  // execution kicked off
numSummer.flatMap { numsum =>
  charConcat.map { string =>
    (numsum, string)
  }
}

右边:

Future { ... }  // execution kicked off
  .flatMap { numsum =>
    Future { ... }  // execution kicked off (Note that this does not happen until
                    // the first future's result (`numsum`) is available.)
      .map { string =>
        (numsum, string)
      }
  }