斯卡拉 – 阿卡未来 – 并行与并发？

插图的要点是Future.apply方法启动了执行,所以如果直到第一个未来的结果是flatMaped(如右图所示),那么你就没有得到并行执行.

(请注意,通过“kicked off”,我的意思是相关的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)
      }
  }