scala中的并发map/foreach

Question

我有一个迭代vals: Iterable[T]和一个长期运行的功能,没有任何相关的副作用:f: (T => Unit).现在这应用于vals显而易见的方式:

vals.foreach(f)

我希望f同时完成调用(在合理的限制内).Scala基础库中某处有明显的功能吗？就像是:

Concurrent.foreach(8 /* Number of threads. */)(vals, f)

虽然f运行时间相当长,但它足够短,我不希望为每个调用调用一个线程的开销,所以我正在寻找基于线程池的东西.

Answer 1

2009年的许多答案仍然使用旧的scala.actors.Futures._,它们不再是新的Scala.虽然Akka是首选方式,但更易读的方法是使用并行(.par)集合:

vals.foreach { v => f(v) }

变

vals.par.foreach { v => f(v) }

或者,使用parMap可能看起来更简洁,但需要记住要记住导入通常的Scalaz*.像往常一样,Scala中有不止一种方法可以做同样的事情!

Answer 2

Scalaz有parMap.您可以按如下方式使用它:

import scalaz.Scalaz._
import scalaz.concurrent.Strategy.Naive

这将为每个函子(包括Iterable)提供一个parMap方法,所以你可以这样做:

vals.parMap(f)

您还可以得到parFlatMap,parZipWith等等.

Answer 3

我喜欢这个Futures答案.但是,虽然它将同时执行,但它也将异步返回,这可能不是你想要的.正确的方法如下:

import scala.actors.Futures._

vals map { x => future { f(x) } } foreach { _() }