Streams-parallel（）跳过（）不显示元素

Question

我有一个关于以下两个代码的问题。

没有平行性：

Stream.of(1, 2, 3)
    .peek(System.out::println)
    .skip(1)
    .map(n-> n * 10)
    .forEach(System.out::println);

输出为：

1
2
20
3
30

具有并行性：

Stream.of(1, 2, 3)
    .parallel()
    .peek(System.out::println)
    .skip(1)
    .map(n-> n * 10)
    .forEach(System.out::println);

输出为：

2
3
20
30

为什么并行流的输出不包括1？

Answer 1

< code>skip()没有问题，您要求跳过< code>1元素，它总是这样做。由< code>Stream.of()创建的流是有序的，并且< code>skip()保证遇到顺序总是被考虑在内。

被限制为不仅跳过任何 n 个元素，而且跳过遭遇顺序中的前 n 个元素。

因为我们在输出中看不到 10，所以这就是 skip（） 正确完成工作的证明 - 元素 1 永远不会到达终端操作。

peek（）没有并行输出（1，未打印）。

这种方法通过副作用运行，并且根据API注释“存在主要是为了支持调试”。与< code > forEach()/< code > forEach ordered()相反，它是一个中间操作，并不意味着执行结果操作。API文档警告说它可能被省略，你不应该依赖它。

副作用的消失也可能令人惊讶。除了终端操作< code>forEach和< code>forEachOrdered之外，当流实现可以优化行为参数的执行而不影响计算结果时，行为参数的副作用可能不总是被执行。