我有一个迭代vals: Iterable[T]和一个长期运行的功能,没有任何相关的副作用:f: (T => Unit).现在这应用于vals显而易见的方式:
vals.foreach(f)我希望f同时完成调用(在合理的限制内).Scala基础库中某处有明显的功能吗？就像是:
Concurrent.foreach(8 /* Number of threads. */)(vals, f)虽然f运行时间相当长,但它足够短,我不希望为每个调用调用一个线程的开销,所以我正在寻找基于线程池的东西.