Scala并行集合中的哪些操作是并行的？
发布时间：2020-12-16 19:08:02 所属栏目：安全 来源：网络整理
导读：似乎当我在并行列表中调用映射时,操作并行运行,但是当我对该列表进行过滤时,操作将严格顺序运行.所以要使滤波器平行,我首先做映射到(A,Boolean),然后过滤这些元组,然后再映射全部.感觉不是很方便. 所以我有兴趣 – 并行集合的哪些操作是并行的,哪些不是？ 解
|
似乎当我在并行列表中调用映射时,操作并行运行,但是当我对该列表进行过滤时,操作将严格顺序运行.所以要使滤波器平行,我首先做映射到(A,Boolean),然后过滤这些元组,然后再映射全部.感觉不是很方便.
所以我有兴趣 – 并行集合的哪些操作是并行的,哪些不是？ 解决方法
没有并行列表.在列表上调用参数将列表转换为默认的并行不可变序列 – 一个ParVector.该转换顺序进行.过滤器和地图应该是平行的.
scala> import scala.collection._
import scala.collection._
scala> List(1,2,3).par.filter { x => println(Thread.currentThread); x > 0 }
Thread[ForkJoinPool-1-worker-5,5,main]
Thread[ForkJoinPool-1-worker-3,main]
Thread[ForkJoinPool-1-worker-0,main]
res0: scala.collection.parallel.immutable.ParSeq[Int] = ParVector(1,3)
也许您已经得出结论,过滤器不是并行的,因为您已经测量了转换时间和过滤器时间. 一些操作目前并不平行：sort * variant,indexOfSlice. （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |