flatMap是否保证是懒惰的？

Question

考虑以下代码：

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

fetchDataFromInternet当第一个URL够用时会被要求输入第二个URL吗？

我尝试了一个较小的示例，它看起来像预期的那样工作。即一个一个地处理数据，但是可以依靠这种行为吗？如果没有，.sequential()在.flatMap(...)帮助之前打电话吗？

    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

更新 ：如果对实施很重要，请使用官方Oracle JDK8

答案 ：根据下面的评论和答案，flatmap部分是惰性的。即完全读取第一个流，并且仅在需要时才读取下一个。渴望读取一个流，但是读取多个流却很懒。

如果有这种行为，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的计算。

编辑

这在Java 10中已得到修复，在Java
10中我们恢复了懒惰：请参阅JDK-8075939

编辑2

这也已在Java
8（8u222）中修复：JDK-8225328