是否有可能,使用Scala的并行集合来并行化并且事先Iterator 没有完全评估它？
这里我谈论的是并行化函数转换Iterator,即map和flatMap.我认为这需要Iterator提前评估一些元素,然后计算更多,一旦消耗了一些元素next.
我所能找到的只需要将迭代器转换为a Iterable或者Stream最多.在Stream当我打电话,然后得到完全评估.par就可以了.
如果没有现成的建议,我也欢迎实施建议.实现应该支持并行map和flatMap.