JavaのparallelStreamが正しい結果を表示していません

Question

私はJavaのaggeragate操作のパフォーマンス評価を行ってコレクションを反復処理していました。私はパフォーマンスstreamとparallelStreamの評価をしていました。しかし、私はparallelStreamの出力がほとんどの時代で間違っていることを発見しました。

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以上80％未満からの間違った出力を得ましたか。 parallelStreamの正確性を保証する方法はありますか？ ありがとう

Answer 1

あなたのコードはcount()の方法で問題があると思います。 parallelStreamは同時にタスクを実行しようとします。このメソッドは​​にするか、totalevenをAtomtic Integerにすることができます。それが役に立てば幸い。

Answer 2

並列ストリームの結果には何が問題なのですか？それが小さすぎると、スレッドセーフではないので、おそらくtotaleven++に問題があります。 AtomicIntegerまたはその他のスレッドセーフなソリューションを使用してください。

Answer 3

の代わりにあなたが

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

totalevenが長いか、鋳造が適用されるデータ型に変更する必要があります例えば、端末操作をStream:count

を使用することができますカウンタをインクリメントするためにはforEachを使用しました。