Java流API惰性评估内部构件

Question

我正在写一篇关于Java流API的文章。我已经阅读了Stream的整个软件包文档，并在这里查看了类似的问题。

如果我说：“直到终端操作被命中，才会评估流上的中间操作，这将实际执行它们，”我是否正确？我在StackOverflow上看到了混合答案，而且每个中间操作都返回一个Stream，所以我想知道它是否只是返回自己，然后只是跟踪要执行的中间操作。这就是“懒惰评估/执行”的意思吗？

下面的javadoc给了我混合的信号。。也许我只是个傻瓜

中间操作返回一个新流。他们总是懒惰；执行中间操作（如filter（））实际上并不执行任何过滤，而是创建一个新的流，在遍历时，该流包含与给定谓词匹配的初始流的元素。在执行管道的终端操作之前，不会开始遍历管道源。

非常感谢您抽出时间！如果我错过了什么，我很抱歉；（我已经在这上面呆了很长时间了！

附注：流和惰性评估非常相似，但是“每个中间操作都会创建一个新流，存储提供的操作/函数并返回新流。”所以基本上，我的问题是，新流是指与给定的流相同吗？

Answer 1

如果我说：“直到终端操作被命中，才对流上的中间操作进行评估，而终端操作将实际执行它们”，我是否正确？

对

我想知道它是否只是自己返回，然后跟踪要执行的中间操作。

不

它返回一个新的Stream对象，该对象是根据之前的Stream对象定义的。

Answer 2

所以我想知道它是不是自己回来了

中间操作不返回给定的流。正如JavaDoc所说，它们返回一个新流，即一个新对象。

如果它是一个新对象，它如何知道以前在流上完成的操作？

...你可能会问。

对象可以引用其他对象，对吗？即使您返回一个执行“映射”的新流，它仍然可以引用“旧流”（即上游）。非常简单的示例：

class StreamThatDoesMapping<U, T> implements Stream<T> {
    private Stream<U> upstream;
    private Function<? super U, ? extends T> mappingFunction;

    public StreamThatDoesMapping(Stream<U> upstream, Function<? super U, ? extends T> mappingFunction) {
        this.upstream = upstream;
        this.mappingFunction = mappingFunction;
    }

    // implementation details...
}

显然，在实现映射时，如果您随后将上游（此）传递给进行映射的流，则新流将“了解”您之前执行的操作！这是您实现映射的方式，同样非常简单：

public <R> Stream<R> map(Function<? super T, ? extends R> mapper) {
    return new StreamThatDoesMapping<>(this, mapper);
}

当您执行终端操作时，您正在“最下游”流对象上执行，该对象将从其上游获取元素，而该上游将从其上游获取元素，依此类推。有点像链表，不是吗？

请注意，这只是下游了解上游的一种方式。可能还有其他的，但这就是ReferencePipeline实现所使用的。这是JDK中大多数stream（）方法返回的内容。我强烈建议查看他们的源代码。