scala - 为什么 Scala 并行集合有时会导致 OutOfMemoryError？

Question

这大约需要 1 秒

(1 to 1000000).map(_+3)

虽然这给 java.lang.OutOfMemoryError: Java 堆空间

(1 to 1000000).par.map(_+3)

编辑:

我有标准的 Scala 2.9.2 配置。我在 Scala 提示符下输入这个。在 bash 中我可以看到 [ -n "$JAVA_OPTS"] || JAVA_OPTS="-Xmx256M -Xms32M"

而且我的环境中没有设置 JAVA_OPTS。

100 万个整数 = 8MB，
创建列表两次 = 16MB

Answer 1

似乎肯定与 JVM 内存选项有关 和 存储 Parralel 集合所需的内存。例如:

scala> (1 to 1000000).par.map(_+3)

以 OutOfMemoryError 结束第三次我试图评估它，而

scala> (1 to 1000000).par.map(_+3).seq

从未失败。问题不在于计算它的并行集合的存储。