Java parallelStream未显示正确结果[重复]

Question

我正在做一些性能评估的Java阿格拉捷操作，以迭代集合。我正在评估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

我认为您的代码与count()方法有问题。因为ParallelStream将尝试并发执行任务。此方法应该是synchronized或者您可以将totaleven设置为原子整数。希望有帮助。