我有一个使用List.par的小程序。
val x = List(1,2,3,4,5).par.map(y => {
Thread.sleep(2000)
println(y)
y + 1
})
println(x)
输出:
3
1
4
5
2
ParVector(2, 3, 4, 5, 6)
数字将并行打印,但返回值始终保持其顺序。
我的目标是在SQL数据库中并行执行一系列insert语句。
目前我正在使用for comprehension。随着语句数量的增加,我想使用ParSeq。
但我担心它会导致性能下降。(如果map实现中有额外的代码来保持其顺序,那么这将是一个性能负担)。
请建议我如何做到这一点。