Java parallelStream没有显示正确的结果[重复]

Question

我正在对迭代集合的 Java aggeragate 操作进行一些性能评估。我正在评估stream 和parallelStream 的性能。但是我发现parallelStream 的输出大多数时候都是错误的。例如，在下面的代码中，我从parallelStream 得到错误输出的概率超过 80%：

    public class ParallelStreamPerformance {
    static int totaleven = 0;
    public static void main(String[] args) {
        List<Integer> randomList = new ArrayList<>();
        Random rnd = new Random();
        for(int i = 0 ;i < 1000;i++) {
            int r = rnd.nextInt(500000);
            randomList.add(r);
        }

        long s1 = System.currentTimeMillis();

        randomList.stream().filter(e -> e%2 ==0).forEach(e -> count());
        System.out.println("Even: "+totaleven);
        long e1 = System.currentTimeMillis();
        System.out.println(e1 - s1);

        totaleven = 0;
        long s2 = System.currentTimeMillis();

        randomList.parallelStream().filter(e -> e%2 ==0).forEach(e -> count());
        System.out.println("Even: "+totaleven);
        long e2 = System.currentTimeMillis();
        System.out.println(e2 - s2);
    }
    public static void count() {
        totaleven++;
    }
}

我的问题是：我是否以错误的方式使用parallelStream？有什么办法可以保证parallelStream的正确性。 谢谢

Answer 1

你可以使用终端操作Stream:count而不是使用forEach来增加一个计数器

例如

totaleven = randomList.stream().filter(e -> e % 2 ==0).count();
totaleven = 0;
totaleven = randomList.parallelStream().filter(e -> e % 2 ==0).count();

totaleven 需要更改为 long 数据类型或应用强制转换。

Answer 2

并行流结果有什么问题？如果它太小，那么您很可能对totaleven++ 有问题，因为它不是线程安全的。使用 AtomicInteger 或任何其他线程安全的解决方案。

Answer 3

我认为您的代码与 count() 方法存在问题。因为parallelStream 将尝试同时执行任务。此方法应为 synchronized 或者您可以将 totaleven 设为 Atomtic Integer。希望对您有所帮助。