elm*_*elm 2 parallel-processing iterator scala
例如,对于给定的迭代器
(1 to 9).grouped(3)
res: Iterator[scala.collection.immutable.IndexedSeq[Int]] = non-empty iterator
Run Code Online (Sandbox Code Playgroud)
如何将其转换为scala.collection.parallel.ParIterable?
您可以使用该to方法将其显式转换为并行集合。例如,使其成为ParVector:
import scala.collection.parallel.immutable.ParVector
(1 to 9).grouped(3).to[ParVector]
Run Code Online (Sandbox Code Playgroud)
Iterator没有par方法,因为没有ParIterator-并行集合API需要整个可用集合才能开始划分工作,因此ParIterator这实际上没有任何意义。
| 归档时间: |
|
| 查看次数: |
358 次 |
| 最近记录: |