パラレルストリームが要素の完全なリストを提供できない理由

Question

ストリームを使用して文字列配列をハッシュマップに変換しています。

String[] arguments= new String[]{"-a","1","-b","2","-c","3","-d","4","-e","5"}; 
    HashMap<String, String> params = new HashMap<>(); 
    IntStream.iterate(0, i -> i + 2) 
      .limit(arguments.length/2) 
      .parallel() 
      .forEach(i -> params.put(arguments[i], arguments[i + 1])); 
    System.out.println(params.size()); 

それは5を示し、時には4

あなたは異なる結果の理由で何ができるか、してください説明してもらえますか？

Answer 1

基本的なストリームプロパティを壊しています。副作用はありません。あなたのストリームにはforEachで副作用があります。簡単な言葉で言えば、複数のスレッドの要素をスレッドセーフでないコレクションHashMapに入れます。

String[] arguments = new String[] { "-a", "1", "-b", "2", "-c", "3", "-d", "4", "-e", "5" }; 
    Map<String, String> map = IntStream.iterate(0, i -> i + 2) 
      .limit(arguments.length/2) 
      .parallel() 
      .boxed() 
      .collect(Collectors.toMap(i -> arguments[i], i -> arguments[i + 1])); 

    System.out.println(map); // {-a=1, -b=2, -c=3, -d=4, -e=5} 

Answer 2

並列ストリームで作業する場合、操作はステートレスでなければなりません。スレッドスケジューリングの違いがあると、結果が不確定になります。

このライン：

.forEach(i -> params.put(arguments[i], arguments[i + 1])); 

は、各実行で異なる結果の原因です。

collect還元操作を利用し、forEachを避けることで問題を解決できます。

あなたはJAVA Stream API内ステートレス行動や副作用に関する詳細な情報を見つけることができます。