好像当我调用 map 时在并行列表上，操作并行运行，但是当我这样做时 filter在该列表中，操作严格按顺序运行。所以要制作filter并行，我首先映射到(A，Boolean)，然后过滤这些元组，然后再次映射回来。感觉不是很方便。
所以我很感兴趣 - 并行集合上的哪些操作是并行化的，哪些不是？
最佳答案
没有平行列表。调用 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 .
关于scala - Scala 并行集合上的哪些操作是并行化的？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/7663903/