以前の計算結果に基づいてJavaストリームの計算を停止する

Question

以前の結果に基づいてストリーム計算を中断するにはどうすればよいですか？ stream.filter（...）。count（）がいくつかの数値より小さいことが明らかな場合 - ストリームの計算を停止する方法は？

// sampleData.size() may be greater than 10.000.000 
Set<String> sampleData = downloadFromWeb(); 
return sampleData.stream().filter(predicate::test).count() > sampleData.size() * coefficient; 

Iは、sampleData数千を有することができる：

は、私はいくつかsampleDataがpredicate試験に合格するかどうかを確認する次のコードを有しています。問題は、このコードが効果がないことです。 coefficientは0.5、sampleData.size() = 10_000_000、最初5_000_000要素が等しい場合たとえば、predicate::test失敗した - 最後5_000_000要素を検証する理由はありません（数は（）より大きく5_000_000なることはありません）。

Answer 1

ZhekaKozlov’s answerは正しい方向に向かっていますが、否定はありません。一致が特定のしきい値よりも大きい場合、一致しない要素の数は「サイズ - しきい値」より小さくなければなりません。私たちは小さいことが一致しない要素をテストする場合、我々は、彼らが大きくなったら停止するlimitを適用することができます。

Set<String> sampleData = downloadFromWeb(); 
final long threshold = sampleData.size()-(long)(sampleData.size() * coefficient); 
return sampleData.stream() 
       .filter(predicate.negate()).limit(threshold+1).count() < threshold; 

ANの試験方法へのメソッドの参照を作成する理由は、方法によって、ありません既存のPredicateはpredicate::testのようです。 Predicateをfilterメソッドに渡すだけです。上記のコードでも、predicate.negate()::testの代わりにpredicate.negate()が使用されています。

Answer 2

Set<String> sampleData = downloadFromWeb(); 
int size = (int) (sampleData.size() * coefficient); 
return sampleData.stream().filter(predicate::test).limit(size + 1).count() > size; 

Answer 3

私はこれが正しいだろうかなりわからない正直に言うと、私は、誰かが一緒に来て、これを確認しますが、ここではカスタムspliteratorを使用しての私の考えであることを願っています：

static class CustomSpl<T> extends AbstractSpliterator<T> { 

    private Spliterator<T> source; 

    private int howMany; 

    private int coefficient; 

    private Predicate<T> predicate; 

    private T current; 

    private long initialSize; 

    private void setT(T t) { 
     this.current = t; 
    } 

    public CustomSpl(Spliterator<T> source, int howMany, int coefficient, Predicate<T> predicate, long initialSize) { 
     super(source.estimateSize(), source.characteristics()); 
     this.source = source; 
     this.howMany = howMany; 
     this.coefficient = coefficient; 
     this.predicate = predicate; 
     this.initialSize = initialSize; 
    } 

    @Override 
    public boolean tryAdvance(Consumer<? super T> action) { 
     boolean hasMore = source.tryAdvance(this::setT); 

     System.out.println(current); 

     if (!hasMore) { 
      return false; 
     } 

     if (predicate.test(current)) { 
      ++howMany; 
     } 

     if (initialSize - howMany <= coefficient) { 
      return false; 
     } 

     action.accept(current); 
     return true; 
    } 

} 

とのために我々は係数5有するだけケアに言っための例では、これは、唯一の4つの要素を生成する：

Spliterator<Integer> sp = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10).stream().spliterator(); 

long count = StreamSupport.stream(new CustomSpl<>(sp, 0, 5, x -> x > 3, sp.getExactSizeIfKnown()), false) 
      .count(); 

をまたこれは、既知のサイズのspliteratorsことが可能です。