并行流上的iterator（）保证遇到顺序？

Question

Stream.of(a, b, c).parallel().map(Object::toString).iterator();

返回的迭代器是否保证按该顺序提供值 a、b、c？

我知道toArray（）和collect（）保证集合的值顺序正确。此外，我并不是在问如何从迭代器生成流。

Answer 1

到目前为止，我发现最接近保证的是java.util.stream包文档中的以下语句：

除了被标识为显式不确定的操作(如findAny())之外，流是顺序执行还是并行执行都不会改变计算的结果。

可以说，iterator（）生成一个以不同顺序迭代的Iterator将是“结果的变化”，就像生成一个包含不同顺序元素的List将用于Collection（）一样。

Answer 2

< code>Stream.of方法用于从不关联的值创建流，返回一个有序的流。

返回元素为指定值的有序流。

根据 Java.util.stream 的软件包“边效应”部分：

IntStream.range（0,5）.parallel（）。地图（x-

这意味着< code>parallel()和< code>map()保留流是否是顺序的/有序的。

我已经跟踪了Stream的实现。的创建到名为ReferencePipeline的类。

@Override
public final Iterator<P_OUT> iterator() {
    return Spliterators.iterator(spliterator());
}

该实现的iterator（）方法遵从Spliterator。iterator（），其代码仅依赖于Spliterator's的tryAdvance方法来适应0.05 iterator接口，并且不会更改任何流特征：

public static<T> Iterator<T> iterator(Spliterator<? extends T> 
    spliterator) {
    Objects.requireNonNull(spliterator);
    class Adapter implements Iterator<T>, Consumer<T> {
        boolean valueReady = false;
        T nextElement;

        @Override
        public void accept(T t) {
            valueReady = true;
            nextElement = t;
        }

        @Override
        public boolean hasNext() {
            if (!valueReady)
                spliterator.tryAdvance(this);
            return valueReady;
        }

        @Override
        public T next() {
            if (!valueReady && !hasNext())
                throw new NoSuchElementException();
            else {
                valueReady = false;
                return nextElement;
            }
        }
    }

    return new Adapter();
}

总之，是的，顺序是有保证的，因为< code>Stream.of创建了一个“顺序有序流”，并且上面使用的任何操作:< code>parallel、< code>map或< code>iterator都不会改变特征。事实上，< code>iterator使用底层流< code>Spliterator来迭代流元素。

Answer 3

这是规范中的一个疏忽。如果一个流有一个定义好的相遇顺序，那么它的目的就是让它的迭代器按照相遇顺序产生元素。如果流没有定义遇到顺序，迭代器当然会以某种顺序产生元素，但是顺序不会被定义。

我已经提交了错误JDK-8194952来跟踪规范的更改。

看起来其他人已经爬取了足够多的实现，以表明它确实会按遇到顺序生成元素。此外，我们的流测试依赖于此属性。例如，toList收集器的测试断言列表中的元素以与从流的Iterator获得的顺序相同的顺序存在。因此，依赖于此行为可能是安全的，即使它还没有正式指定。