为什么总是forEach
以随机顺序打印数字,而collect
始终从原始顺序收集元素,即使是从并行流中呢?
Integer[] intArray = {1, 2, 3, 4, 5, 6, 7, 8};
List<Integer> listOfIntegers = new ArrayList<>(Arrays.asList(intArray));
System.out.println("Parallel Stream: ");
listOfIntegers
.stream()
.parallel()
.forEach(e -> System.out.print(e + " "));
System.out.println();
// Collectors
List<Integer> l = listOfIntegers
.stream()
.parallel()
.collect(Collectors.toList());
System.out.println(l);
输出:
Parallel Stream:
8 1 6 2 7 4 5 3
[1, 2, 3, 4, 5, 6, 7, 8]
这里有两种不同的“排序”,使讨论变得混乱。
一种是遇到顺序,该顺序在流文档中定义。考虑这一点的一种好方法是源集合中元素的空间顺序或从左到右的顺序。如果源是List
,请考虑将较早的元素放在后面的元素的左侧。
还有文档中未定义的处理或时间顺序,但这是由不同线程处理元素的时间顺序。如果列表的元素由不同的线程并行处理,则线程可能在列表中最右边的元素之前处理最右边的元素。但是下次可能不会。
即使并行执行计算,大多数Collectors
和某些终端操作也会精心安排,以便它们保留从源到目的地的遇到顺序,而与不同线程处理每个元素的时间顺序无关。
需要注意的是,forEach
终端的操作并不能保留相遇秩序。相反,它由发生任何下一个结果的线程运行。如果您想要这样的东西forEach
来保留相遇顺序,请forEachOrdered
改用。
另请参阅Lambda常见问题解答,以进一步了解订购问题。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句