小编Vas*_*sco的帖子

scala并行集合不一致

我从下面的代码得到了不一致的答案,我觉得很奇怪.

import scala.math.pow

val p = 2
val a = Array(1,2,3)

println(a.par
    .aggregate("0")((x, y) => s"$y pow $p; ", (x, y) => x + y))

for (i <- 1 to 100) {
  println(a.par
    .aggregate(0.0)((x, y) => pow(y, p), (x, y) => x + y) == 14)
}

a.map(x => pow(x,p)).sum
Run Code Online (Sandbox Code Playgroud)

在代码中a.par ...计算14 10.任何人都可以解释为什么计算不一致吗?

parallel-processing scala

0
推荐指数
1
解决办法
57
查看次数

标签 统计

parallel-processing ×1

scala ×1