シーケンシャルストリーム操作に副作用がありますか？

Question

限られた数の値をセットにストリーミングしようとしていますが、制限を適用する前に新しい要素であることを確認する必要があります。たとえば：add()は両方それがコレクションに新しいのかどうかの要素とレポートを追加することができますので、

Set<Integer> destination = ... 
Set<Integer> source = ... 
source.stream() 
     .filter(i -> !destination.contains(i)) 
     .limit(10) 
     .forEach(destination::add); 

しかし、冗長チェックは、私を悩ませています。だから私はこれを行うことを考えていた：

source.stream() 
     .filter(destination::add) 
     .limit(10) 
     .forEach(i -> {}); // no-op terminal operation to force evaluation 

がハック端末操作を無視すると、一般的に推奨されて副作用、とフィルタ操作を使用しての問題があります。私は、並列ストリームで副作用を伴うmap()とfilter()を使用することが安全でない理由を理解しています。私の質問は、この場合のように連続したストリームで受け入れられるだろうか？そうでない場合は、どうしてですか？

Answer 1

副作用と順次ストリームには基本的な問題はありませんが、ストリームAPIは各要素が各要素で実行されることを保証しないため、上記の2番目の実装は無効です

2番目の実装では、制限が適用される前に、10個以上の要素がdestinationに追加されます。あなたのノー・フォー・フォーには10枚しか見えませんが、あなたはセットでさらに多くなることがあります。

ストリームに加えて、javaにはforとwhileのようなループ構造があり、このようなことを簡単に表現できます。

あなた必見利用の流れならば、あなたはこのようにそれを行うことができます。述語がfalseを返すよう

int maxSize = destination.size()+10; 
source.stream().allMatch(x -> destination.size()<maxsize && (destination.add(x)||true)); 

allMatchとすぐに反復を停止します。

Answer 2

があなたのためにこの作業を行います。

このクラスウィル印刷実行

package be.objectsmith; 

import java.util.Arrays; 
import java.util.HashSet; 
import java.util.Set; 
import java.util.stream.Collectors; 
import java.util.stream.IntStream; 

public class Playground { 
    public static void main(String[] args) { 
     copy(
      IntStream.range(1, 20).boxed().collect(Collectors.toSet()), 
      new HashSet<>(Arrays.asList(2, 5))); 
     copy(
      IntStream.range(1, 5).boxed().collect(Collectors.toSet()), 
      new HashSet<>(Arrays.asList(2, 5))); 
    } 

    private static void copy(Set<Integer> source, Set<Integer> destination) { 
     source 
      .stream() 
      .map(destination::add) 
      .filter(resultOfAdding -> resultOfAdding) 
      .limit(10) 
      .collect(Collectors.toList()); // Need a terminal operation 
     System.out.println("source = " + source); 
     System.out.println("destination = " + destination); 
    } 

} 

：あなたが見ることができるように

source = [1, 2, 3, 4] 
destination = [1, 2, 3, 4, 5] 
source = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19] 
destination = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12] 

を、それだけで10個の要素を追加しました。 2つ目の呼び出しは、追加する要素が10個未満の場合にも機能することを示しています。