遇到订单友好/不友好的终端操作与并行/顺序与有序/无序流

Question

受这个问题的启发，我开始研究有序流与无序流、并行流与顺序流以及终端操作，它们考虑的是相遇顺序，而终端操作则不考虑相遇顺序。

在链接问题的一个答案中，显示了一个类似于此的代码：

List<Integer> ordered = Arrays.asList(
    1, 2, 3, 4, 4, 3, 2, 1, 1, 2, 3, 4, 4, 3, 2, 1, 1, 2, 3, 4);
List<Integer> result = new CopyOnWriteArrayList<>();

ordered.parallelStream().forEach(result::add);

System.out.println(ordered);
System.out.println(result);

名单确实不同。无序列表甚至从一次运行更改到另一次运行，表明结果实际上是不确定的。

因此，我创建了另一个示例：

CopyOnWriteArrayList<Integer> result2 = ordered.parallelStream()
        .unordered()
        .collect(Collectors.toCollection(CopyOnWriteArrayList::new));

System.out.println(ordered);
System.out.println(result2);

我希望看到类似的结果，因为流既并行又无序（可能unordered（）是冗余的，因为它已经并行了）。但是，结果列表是有序的，即它等于源列表。

所以我的问题是为什么要订购收集的列表？收集是否总是尊重相遇顺序，即使是并行的、无序的流？是特定的Collectors.to集合（...）收集器强制遭遇顺序？

Answer 1

留档流#收藏已经提到：

当并行执行时，可以实例化、填充和合并多个中间结果，以保持可变数据结构的隔离。因此，即使在与非线程安全的数据结构（如ArrayList）并行执行时，并行缩减也不需要额外的同步。

这意味着流#collect做两件主要的事情：split

但是我在jdk-8中有一个特殊的例子，你可以获取不同的结果：）。当创建一个无序的流流由流#生成，然后你可以在收藏家#toList上获取不同的结果，例如：

Set<Set<Integer>> result = IntStream.range(0, 10).mapToObj(__ -> {
        return unordered().parallel().collect(toSet());
}).collect(toSet());

assert result.each.size() == 100000; // ok
//                   v--- surprised, it was pass 
assert result.size() > 1; 

Stream<Integer> unordered() {
    AtomicInteger counter = new AtomicInteger();
    return Stream.generate(counter::getAndIncrement).limit(10000);
}

Answer 2

在当前的实现中，我检查了java-8和java-9，对于非并发收集器（Collector.Characteristics.unordered），在collect阶段忽略无序标志。实现是允许这样做的，这在某种程度上是一个类似的问题。

在您链接的同一个问题中，我提供了一个示例，说明了findFirst实际上是如何从jdk-8更改为jdk-9的。

Answer 3

收集器。toCollection返回一个收集器，该收集器缺少收集器。特点。无序特征。指定收集器的另一个收集器。特点。无序的可能表现不同。

也就是说：“无序”意味着没有保证，不保证变化。如果库发现最容易将无序的集合按顺序处理，则允许它这样做，并且允许该行为在星期二或满月时一个版本一个版本地更改。

（还请注意，如果要使用并行流，Collectors.to集合不需要使用并发集合实现；toCollection（ArrayList::new）可以正常工作。这是因为收集器没有收集器。特点。（CONCURRENT特性，因此它使用了一种即使在并行流中也适用于非并发集合的集合策略。）（

如果您使用的是无序流，但收集器不是无序的，反之亦然，我怀疑您是否能从框架中得到任何保证。如果有一张桌子，它会说“给你。”

对于流。collect，我认为当前的实施有三种策略可供选择：

• 顺序：启动一个累加器，将元素累加到累加器中（按遭遇顺序，因为你为什么要费事洗牌这些元素？只需按你得到它们的顺序接受它们），调用finisher