java流中的顺序保持

Question

我已经讨论了一些相关问题，比如如何确保java8流中的处理顺序？，我仍然不完全清楚输出元素的顺序。因此，请澄清我的以下疑问。

 Integer[] intArray = {1, 2, 3, 4, 5, 6, 7, 8 };
            List<Integer> listOfIntegers =
                new ArrayList<>(Arrays.asList(intArray));
       listOfIntegers
            .parallelStream()
             .unordered()
            .forEachOrdered(e -> System.out.print(e + " "));

我认为至少在理论上（或根据java规范），它可以按1、2、3、4、5、6、7、8以外的随机顺序打印。我说得对吗？

还有一个相关的问题——遭遇订单保存的决定是在执行的哪个点做出的？更准确地说，在执行开始之前，是否通过检查源、中间操作和终端操作的特性来评估整个流水线的订单特性？

Answer 1

一旦你选择了无序，那么最终结果基本上是以随机顺序出现的。请注意，虽然没有要求它这样做，但事实上，您可能仍然会在输出中看到一些排序。

forEachOrdered保留“流”的遭遇顺序，因此如果没有。无序（）。如果流已经无序，那么它是毫无意义的，您也可以使用forEach。

换句话说，forEachOrdered在已经排序的流中保留遭遇顺序。它不进行任何排序或其他排序，但是如果流已经是无序的，那么任何事情都可能发生。

Answer 2

源代码的无序性质或通过无序（）显式释放订单合同可能会影响所有后续管道阶段，除非它们引入了只能通过排序操作发生的订单。

对于无状态的中间操作，如filter和map，无论如何都没有区别，但是像skip、limit和distinct这样的操作可能会表现出不同的行为，这取决于之前的流状态是有序的还是无序的。这个答案展示了一个例子，说明了前一个unordered（）如何影响distinct。

请注意，原则上，排序，在引入顺序时，可能取决于前一阶段的有序状态，因为如果前一个流无序，它可能会使用不稳定的排序算法。

这个答案提供了一种方法来打印流的特征，并评估它们如何因附加另一个操作而改变。

当链接一个终端操作时，终端操作本身的无序性质或终端操作前最后阶段的无序状态可能足以为终端操作选择一个不试图保持顺序的算法。

原则上，终端操作的无序性质可用于影响之前的阶段，但由于无状态中间操作无论如何都不会受到影响，skip，limit，distinct必须遵守之前的有序状态，如果存在，则是唯一可能受到影响的操作，如果后续操作不关心顺序，则排序后的将过时。

在当前的实现中，自从Java

所以

list.stream() // List.stream() returns an ordered stream
    .unordered() // releases order contract
    .distinct() // for equal elements, it may pick an arbitrary one
    .sorted() // re-introduces an order
    .skip(1) // will skip the minimum element due to the order
    .forEach(System.out::println); // may print the remaining elements in arbitrary order

流管道没有单一的有序或无序行为。

相比之下，与

hashSet.stream() // HashSet.stream() has no order (unless being a LinkedHashSet)
    .filter(Objects::nonNull) // not affected by order
    .distinct() // may use unorderedness, but has no effect anyway, as already distinct
    .skip(1) // may skip an arbitrary element
    .forEachOrdered(System.out::println); // would respect order if there was one

整个管道都是无序运行的，因为源是无序的。有了有序的源，它将是完全有序的。

所以，问题的答案是“整个流管道顺序特性的评估是在执行开始之前通过源、中间操作和终端操作的特性来完成的吗？”是的，这是在开始实际处理之前完成的，通过为管道阶段选择合适的算法，当有选择时，但这个过程不一定会导致整个管道的单一特征。