如果你添加 par 那么你将得到一个并行的集合,并且它的操作将被并行处理。要转换回正常的集合,请调用a toList 。
par
toList
所以你的代码看起来像:
a.par.map(tup => tup._1 + tup._2).toList
或者a .seq 得到一个连续收集( 相反 并行收藏)。
.seq
a.par.map(tup => tup._1 + tup._2).seq
另外,请查看文档。
par 拆分列表以便处理多个线程。然后你可以通过调整线程来调节线程的完成方式 tasksupport 结果的成员 ParSeq 。
tasksupport
ParSeq