flatMap保证会偷懒吗？[副本]

Question

urls.stream()
    .flatMap(url -> fetchDataFromInternet(url).stream())
    .filter(...)
    .findFirst()
    .get();

    Stream.of("one", "two", "three")
            .flatMap(num -> {
                System.out.println("Processing " + num);
                // return FetchFromInternetForNum(num).data().stream();
                return Stream.of(num);
            })
            .peek(num -> System.out.println("Peek before filter: "+ num))
            .filter(num -> num.length() > 0)
            .peek(num -> System.out.println("Peek after filter: "+ num))
            .forEach(num -> {
                System.out.println("Done " + num);
            });

输出：

Processing one
Peek before filter: one
Peek after filter: one
Done one
Processing two
Peek before filter: two
Peek after filter: two
Done two
Processing three
Peek before filter: three
Peek after filter: three
Done three

如果要执行此行为，API应该让函数返回iterable而不是流。

换句话说：链接

Answer 1

在当前的实现下，flatmap是急切的；与任何其他有状态的中间操作（如sorted和distinct)一样。而且很容易证明：

 int result = Stream.of(1)
            .flatMap(x -> Stream.generate(() -> ThreadLocalRandom.current().nextInt()))
            .findFirst()
            .get();

    System.out.println(result);

当flatmap被急切地计算时，这永远不会结束。对于您的示例：

urls.stream()
    .flatMap(url -> fetchDataFromInternet(url).stream())
    .filter(...)
    .findFirst()
    .get();

这意味着对于每个URL，FlatMap将阻止后面的所有其他操作，即使您只关心一个操作。因此，假设从单个url中，您的FetchDataFromInternet(url)生成10_000行，那么您的FindFirst将不得不等待计算出所有10_000，即使您只关心其中一个。

编辑

这在Java10中得到了修正，在这里我们又找回了懒惰：参见JDK-8075939

编辑2