从集合中获取并行流

Question

在Java8中，您需要执行以下代码才能从集合中获得并行流，这是否正确？

private <E> void process(final Collection<E> collection) {
    Stream<E> stream = collection.parallelStream().parallel();
    //processing
}

来自集合API：

默认流parallelStream（）

Answer 1

基本上，collection.parallelStream()的默认实现会创建并行流。实现如下所示：

default Stream<E> parallelStream() {
    return StreamSupport.stream(spliterator(), true);
}

但是这是一个默认的方法，对于一些实现类来说，提供一个不同的实现来创建顺序流是完全有效的。例如，假设我创建了SequentialArrayList:

class MySequentialArrayList extends ArrayList<String> {
    @Override
    public Stream<String> parallelStream() {
        return StreamSupport.stream(spliterator(), false);
    }
}

对于该类的对象，以下代码将按预期打印false:

ArrayList<String> arrayList = new MySequentialArrayList();
System.out.println(arrayList.parallelStream().isParallel());

public final S parallel() {
    sourceStage.parallel = true;
    return (S) this;
}

System.out.println(arrayList.parallelStream().parallel().isParallel());