找到流直到值-可选[重复]

Question

我想在找到第一个值时终止流的执行。然而，当我运行下面的代码时，它显示，即使第一个方法中存在值，也会调用两个方法。

public static void main(String[] args) {

        Optional<String> s = Stream.of(first(), second())
                .filter(Optional::isPresent)
                .findFirst()
                .flatMap(Function.identity());

        System.out.println(s.get());
    }

    private static Optional<String> first() {
        System.out.println("first");
        return Optional.of("someValue");
    }

    private static Optional<String> second() {
        System.out.println("second");
        return Optional.empty();
    }

我登记了文件：

1. 表示

如果存在值，则返回{@code true}，否则返回{@code false}。

返回描述此流的第一个元素的{@link Optional}，如果流为空，则返回空的{@code Optional}。如果流没有遭遇顺序，那么可以返回任何元素。

所以它满足了第一个条件，第二个条件似乎也满足了，因为它回来了：

first
second
someValue

如果出现第一个值，如何退出执行，而不执行第二个方法？

Answer 1

问题不在于findFirst不是短路，而是流。of（first（），second（））导致立即（而不是延迟）执行first（）和second。它本质上是作为任何普通表达式计算的。

换句话说，即使你的主要方法只是

final public static void main(String[] args) throws Exception {
    Stream.of(first(), second());
}

它仍然会立即执行first（）和second（）。

Answer 2

如果出现第一个值，如何退出执行，而不执行第二个方法？

Stream#findFirst是一种短路终端操作。然而，当您调用流时，这些方法正在被调用。of（first（），second（））。这可以通过以下代码片段来证明：

Optional<String> s = Stream.of(first(), second())
                           .peek($ -> System.out.println("Hello World!"))
                           .filter(Optional::isPresent)
                           .findFirst()
                           .flatMap(Function.identity());

System.out.println(s.get());

输出：

first
second
Hello World!
someValue

为了防止调用的流时执行first（）和second（），一种解决方案是将它们包装在供应商中

Stream<Supplier<Optional<String>>> stream = Stream.of(Test::first, Test::second);

Optional<String> s = stream.map(Supplier::get)
                           .filter(Optional::isPresent)
                           .findFirst()
                           .flatMap(Function.identity());

System.out.println(s.get());

输出：

first
someValue