scala - Scala 并行集合上的哪些操作是并行化的？

Question

好像当我调用 map 时在并行列表上，操作并行运行，但是当我这样做时 filter在该列表中，操作严格按顺序运行。所以要制作filter并行，我首先映射到(A，Boolean)，然后过滤这些元组，然后再次映射回来。感觉不是很方便。

所以我很感兴趣 - 并行集合上的哪些操作是并行化的，哪些不是？

Answer 1

没有平行列表。调用 par在 List转换 List进入默认的并行不可变序列 - a ParVector .该转换按顺序进行。两者filter和 map那么应该是平行的。

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,5,main]
Thread[ForkJoinPool-1-worker-0,5,main]
res0: scala.collection.parallel.immutable.ParSeq[Int] = ParVector(1, 2, 3)

也许您已经得出结论， filter不是并行的，因为您已经测量了转换时间和 filter时间。

一些当前未并行化的操作: sort*变体， indexOfSlice .