并发地图/ foreach在scala
发布时间：2020-12-16 09:22:09 所属栏目：安全 来源：网络整理
导读：我有一个迭代值：Iterable [T]和一个长时间运行的函数,没有任何相关的副作用：f：(T = Unit).现在这是以明显的方式应用于vals： vals.foreach(f) 我希望对f的呼吁同时进行(在合理的范围内). Scala基础库中某处有明显的功能吗？就像是： Concurrent.foreach(8
|
我有一个迭代值：Iterable [T]和一个长时间运行的函数,没有任何相关的副作用：f：(T => Unit).现在这是以明显的方式应用于vals：
vals.foreach(f) 我希望对f的呼吁同时进行(在合理的范围内). Scala基础库中某处有明显的功能吗？就像是： Concurrent.foreach(8 /* Number of threads. */)(vals,f) 当f运行相当长时,它足够短,我不希望为每个调用调用一个线程的开销,所以我正在寻找一个基于线程池的东西. 解决方法
我喜欢期货答案.但是,它将同时执行,它也将异步返回,这可能不是你想要的.正确的做法如下：
import scala.actors.Futures._
vals map { x => future { f(x) } } foreach { _() }
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |