用Java有限生成的流-如何创建一个？

Question

在Java中，可以轻松地生成无限流Stream.generate(supplier)。但是，我需要生成一个最终将完成的流。

想象一下，例如，我想要目录中所有文件的流。文件的数量可能很大，因此我无法预先收集所有数据并通过它们（通过collection.stream()）创建流。我需要逐段生成序列。但是流显然会在某个时刻结束，并且像（collect()或findAny()）这样的终端运营商需要对其进行处理，因此Stream.generate(supplier)不适合在这里使用。

是否有任何合理的简便方法可以用Java实现，而无需自己实现整个Stream接口？

我可以想到一个简单的技巧-
使用infinite进行操作Stream.generate(supplier)，并在获取所有实际值时提供null或引发异常。但这会破坏标准的流运算符，我只能将其与意识到这一行为的我自己的运算符一起使用。

澄清说明

评论中的人向我takeWhile()求助。这不是我的意思。如何更好地表达问题……我不是在问如何过滤（或限制）现有的流，而是在问如何动态创建（生成）流，而无需预先加载所有元素，但是该流将具有有限大小（事先未知）。

解

我一直在寻找的代码是

    Iterator it = myCustomIteratorThatGeneratesTheSequence();
    StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, Spliterator.DISTINCT), false);

我刚刚调查java.nio.file.Files了该list(path)方法的实现方式。

Answer 1

是否有任何合理的简便方法可以用Java实现，而无需自己实现整个Stream接口？

一个简单的.limit()保证，它将终止。但这并不总是那么强大。

使用Stream工厂方法后，创建海关流源而不重新实现流处理管道的最简单方法是java.util.Spliterators.AbstractSpliterator<T>将其子类化并传递给java.util.stream.StreamSupport.stream(Supplier<? extends Spliterator<T>>, int, boolean)

如果您打算使用并行流，请注意，AbstractSpliterator只会产生次佳的拆分。如果您对源代码有更多控制权，则完全实现该Spliterator接口会更好。

例如，以下代码片段将创建一个提供无限序列1,2,3 …的Stream。

在该特定示例中，您可以使用 IntStream.range()

但是流显然会在某个时刻结束，并且终端操作符（如（collect（）或findAny（）））需要对其进行处理。

findAny()只要有任何匹配的元素，像这样的短路操作实际上就可以在无限流上完成。

Java
9引入了Stream.iterate来为某些简单情况生成有限的流。