skip（）方法是短路操作吗？

Question

我正在阅读Java streams的短路操作，在一些文章中发现，skip（）是一种短路操作。

在另一篇文章中，他们没有提到短路操作。

现在我很困惑；skip（）是短路操作还是不是？

Answer 1

只想在这里加上我的两分钱，一般来说，让一条流短路的想法是无限复杂的（至少对我来说，至少在这个意义上，我通常要搔两次头）。顺便说一句，我将在回答结束时跳过。

举个例子：

Stream.generate(() -> Integer.MAX_VALUE);

这是一个无限流，我们都同意这一点。让我们通过记录为这样的操作来短路它（与skip不同）：

Stream.generate(() -> Integer.MAX_VALUE).anyMatch(x -> true);

这很好，添加一个过滤器怎么样

Stream.generate(() -> Integer.MAX_VALUE)
      .filter(x -> x < 100) // well sort of useless...
      .anyMatch(x -> true);

这里会发生什么？好吧，这永远不会结束，即使有像anyMatch这样的短路操作-但它从未达到真正短路任何东西。

另一方面，filter不是短路操作，但您可以这样做（仅作为示例）：

someList.stream()
        .filter(x -> {
           if(x > 3) throw AssertionError("Just because");            
})

是的，它很难看，但它短路了。。。这就是我们（强调我们，因为许多人不同意）实现短路减少的方式-抛出一个没有堆栈跟踪的异常。

在java-9中，添加了另一个短路的中间操作：takAh，其行为有点像限制，但对于特定条件。

公平地说，关于skip的大部分答案是Aomine已经给出的，但最简单的答案是它没有这样的文档记录。一般来说（在某些情况下，文档已更正），但这是您应该注意的首要指示。例如，请参见明确说明：

这是一种短路状态中间操作

Answer 2

来自“流操作和管道”部分下的java文档：

如果中间操作在输入无限时可能产生有限流，则中间操作为短路。当输入无限大时，如果终端操作可能在有限时间内终止，则终端操作为短路。

强调我的。

如果您要在无限输入上调用skip，它不会产生有限流，因此不会产生短路操作。

JDK8中唯一的短路中间操作是限制，因为它允许在有限时间内完成无限流上的计算。

例子：

如果要使用跳过来执行此程序：

String[] skip = Stream.generate(() -> "test") // returns an infinite stream
                      .skip(20) 
                      .toArray(String[]::new);

它不会产生有限的流，因此最终会得到类似“java.lang.OutOfMemoryError:java堆空间”的东西。

而如果您要使用limited执行此程序，它将导致计算在有限时间内完成：

String[] limit = Stream.generate(() -> "test") // returns an infinite stream
                       .limit(20)
                       .toArray(String[]::new);