Scala可迭代到可迭代

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?

win*_*ner 5

您可以使用该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这实际上没有任何意义。