Java 8，在流中使用.parallel会导致OOM错误

Java 8，在流中使用.parallel会导致OOM错误

在这里，您可以创建无限流并在之后对其进行限制。关于并行处理无限流存在已知问题。特别是，无法有效地将任务分成相等的部分。在内部使用了一些启发式方法，这些启发式方法不太适合每个任务。在您的情况下，最好使用创建有限流

LongStream.range

：

import java.util.stream.LongStream;public class ParallelPlay {    public static void main(String[] args) {        System.out.println(parallelSum(100_000_000));    }    public static long parallelSum(long n) {        return LongStream.rangeClosed(1, n).parallel().sum();    }}

在这种情况下，Stream引擎从一开始就知道您有多少个元素，因此它可以有效地拆分任务。另请注意，使用

LongStream

会更有效，因为您将没有不必要的装箱。

通常，如果可以用有限的流解决任务，请避免使用无限的流。