Scala並行集合上的哪些操作是並行化的？

Question

好像當我在並行列表上調用map時，該操作並行運行，但是當我在該列表上執行filter時，操作嚴格按順序運行。因此，爲了使filter平行，我首先映射到（A，布爾），然後過濾這些元組，然後再映射回來。感覺不是很方便。

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

Answer 1

沒有平行列表。在List上調用par可將List轉換爲默認的並行不可變序列 - 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。