如何短路减少流？

Question

假设我有一个布尔值流，而我正在编写的reduce操作是||（OR）。我是否可以这样编写它：如果true遇到值，则放弃对至少某些元素的求值？

我正在寻找某种程度的优化（也许是并行流），不一定要完全优化，尽管后者会很棒。

Answer 1

我怀疑您想要这种构造。

// stop when any element evaluates to true
boolean any = stream.anyMatch(t -> t);

你可以看一下

Stream.of(1, 2, 3, 4).peek(System.out::println).anyMatch(i -> i == 2);
版画

1
2

举个平行的例子

AtomicInteger count = new AtomicInteger();
IntStream.range(0, 1000).parallel().peek(t -> count.incrementAndGet()).anyMatch(i -> i == 2);
System.out.println("count: " + count);

打印一个像

count: 223确切数字有所不同。

对于referencePipeline，anyMatch调用

@Override
public final boolean anyMatch(Predicate<? super P_OUT> predicate) {
    return evaluate(MatchOps.makeRef(predicate, MatchOps.MatchKind.ANY));
}

叫这个

public static <T> TerminalOp<T, Boolean> makeRef(Predicate<? super T> predicate,
        MatchKind matchKind) {
    Objects.requireNonNull(predicate);
    Objects.requireNonNull(matchKind);
    class MatchSink extends BooleanTerminalSink<T> {
        MatchSink() {
            super(matchKind);
        }

        @Override
        public void accept(T t) {
            if (!stop && predicate.test(t) == matchKind.stopOnPredicateMatches) {
                stop = true;
                value = matchKind.shortCircuitResult;
            }
        }
    }

    return new MatchOp<>(StreamShape.REFERENCE, matchKind, MatchSink::new);
}

在这里您可以开始看到短路代码。