Java 8 findFirst和遇到顺序

Question

在对JavaDoc中findFirst说，如果流有一个邂逅的命令，那么第一个元素总是会返回，但如果流没有遭遇订单，可以返回的任何元素。

我试图证明它在没有遇到顺序的情况下如何在流中工作，但是我无法让它返回除实际第一个元素以外的任何东西。

我尝试将元素添加到中Set，该元素没有定义的遇到顺序：

    Set<String> words = new HashSet<>();
    words.addAll(Arrays.asList("this", "is", "a", "stream", "of", "strings"));
    Optional<String> firstString = words.stream()
            .findFirst();
    System.out.println(firstString);

每次运行时，我都会得到a第一个字符串。然后，我尝试Collections.shuffle对进行，List然后再将其添加到中Set，但这并没有改变任何内容。

    List<String> wordList = Arrays.asList("this", "is", "a", "stream", "of", "strings");
    words = new HashSet<>();
    words.addAll(wordList);
    firstString = words.stream()
            .findFirst();
    System.out.println(firstString);

a每次我仍然记得这个词。

然后，我尝试使用unorderedfrom中的方法BaseStream，该方法声称返回的流没有遇到顺序，但是没有区别：

    firstString = Stream.of("this", "is", "a", "stream", "of", "strings")
            .unordered()
            .findFirst();
    System.out.println(firstString);

现在我this每次都能听到这个词。我想念什么吗？有什么方法可以证明findFirst在无序流上返回不同的值？

Answer 1

好吧，“任何”都包括“第一”的可能性。当然，Stream实现不会浪费数据的随机性，因此在很多情况下，尤其是在顺序执行中，如果我们可以这样调用它，它仍然将是第一个元素（因为没有顺序，有没有明显的第一个元素）。

展示不同结果的最佳机会findFirst是使用并行Streams。但是即使在那儿，并非每种操作组合都适合表现出无序性。

一点是，在当前实现中，当Stream无序时，该findFirst() 操作不会更改其行为，即，它不会主动尝试成为like findAny()。由于Stream的来源，它仍然可能表现出不可预测的行为，但是如果您的来源是Stream.of("this", "is", "a", "stream", "of", "strings")，即已知大小的不可变序列，则它已经具有最佳的并行性能，因此根本无法从链式中受益unordered()，因此，当前的实现不会改变其行为。

这可能会令人惊讶，但这甚至HashSet在某种程度上也适用。尽管它的顺序不确定，但是在某些时候它的后备数组中会有一个实际顺序，只要您不修改Set，就没有理由将这些条目改组，因此对于特定的HashSet情况，您可能会反复获得相同的“第一个”元素，尽管没有指定哪个元素，甚至在单个运行时中，另一个HashSet实例表示相同的内容，但具有不同的历史记录，可能具有不同的顺序。

已知可以从无序特性中受益的一种操作示例是distinct。尽管它必须对重复项进行分类，但是如果有显着差异，它必须保留第一次遇到的相等元素。这会大大降低性能，因此，如果流是无序的，则实现将立即尝试获得好处。例如

List<String> equal=IntStream.range(0, 100)
    .mapToObj(i->new String("test")) // don't do this in normal code
    .collect(Collectors.toList());
Map<String, Integer> map = IntStream.range(0, equal.size())
    .collect(IdentityHashMap::new, (m,i)->m.put(equal.get(i),i), Map::putAll);

equal.parallelStream().distinct().map(map::get)
     .findFirst().ifPresent(System.out::println);

这会创建一堆equal但可区分的String实例（通常不应该这样做），并将它们的位置编号注册到中IdentityHashMap，以便我们找出distinct保留了哪个实例。由于上面的代码使用了由创建的有序流List，因此0无论您执行频率如何，它都将始终打印。

相反，

equal.parallelStream().unordered().distinct().map(map::get)
     .findFirst().ifPresent(System.out::println);

将释放任意数量的范围，因为我们已经释放了订购合同并允许选择任意相等的字符串。

如前所述，这都是特定于实现的。您永远不要假设某个操作是否可以真正带来好处，从而改变无序流的行为。上面的解释仅是为了说明为什么有时特定实现的行为对于无序流可能不会改变。虽然如此，它仍可能在下一版本或其他JRE实现中。