流中间操作排序

Question

List<String> list = Arrays.asList("a", "b", "c");
List<String> modified = list.parallelStream()
        .map(s -> s + "-" + s)                 //"a-a", "b-b", "c-c"
        .filter(s -> !s.equals("b-b"))         //"a-a", "c-c"
        .map(s -> s.substring(2))              //"a", "c"
        .collect(toList());

Answer 1

实际上，在原始问题中嵌入了几个关于排序的问题。

Holger的回答涵盖了流水线内流操作的排序。对于一个特定的流元素，管道操作必须按照程序中所写的方式执行，因为一般来说，类型必须匹配，而且，以其他方式执行也没有意义。从最初的示例开始，streams库不能像编写操作一样重新排序操作，

List<String> modified = list.parallelStream()
    .filter(s -> !s.equals("b-b")) // these two operations are swapped
    .map(s -> s + "-" + s)         // compared to the original example
    .map(s -> s.substring(2))
    .collect(toList());

因为这样的结果将是[a，b，c]。这不会发生的。

List<String> list = Arrays.asList("c", "b", "a");
List<String> modified = list.parallelStream()
    .map(s -> s + "-" + s)                 //"c-c", "b-b", "a-a"
    .filter(s -> !s.equals("b-b"))         //"c-c", "a-a"
    .map(s -> s.substring(2))              //"c", "a"
    .collect(toList());

正如我们所料，输出是[c,a]。现在让我们在一个集合而不是列表上运行流：

List<String> list = Arrays.asList("c", "b", "a");
Set<String> set = new HashSet<>(list);
List<String> modified = set.parallelStream()
    .map(s -> s + "-" + s)
    .filter(s -> !s.equals("b-b"))
    .map(s -> s.substring(2))
    .collect(toList());

这一次，结果是[a，c]。流水线操作(map、filter、map)没有更改顺序，但是由于集合中元素的相遇顺序未定义，结果以与以前结果不同的某种顺序出现在目标列表中。

（我不得不更改原始列表中值的顺序，因为碰巧HashSet的迭代顺序与元素的hashcode相关，这里给出的简单字符串示例具有连续的hashcode。）

List<Integer> list1 = Collections.synchronizedList(new ArrayList<>());
List<Integer> list2 =
    IntStream.range(0, 10)
        .parallel()
        .boxed()
        .peek(i -> list1.add(i))
        .collect(toList());
System.out.println(list1);
System.out.println(list2);

在我的系统上，输出是：

[5, 6, 2, 3, 4, 8, 9, 7, 0, 1]
[0, 1, 2, 3, 4, 5, 6, 7, 8, 9]

在清单2中，源的遭遇顺序保留到输出，但清单1的顺序通常不同。事实上，list1中元素的顺序因运行而异，而list2中元素的顺序总是相同的。

总之，这里显示了三种不同的排序：

null