理解Java8和Java9中的序列流拆分器与并行流拆分器

Question

stream.spliterator()与stream.parallel（）.spliterator()之间的差异：

>

它们可能有不同的特点：

Stream.of(1L, 2L, 3L).limit(2);            // ORDERED
Stream.of(1L, 2L, 3L).limit(2).parallel(); // SUBSIZED, SIZED, ORDERED

这里讨论的似乎是另一个毫无意义的流拆分器特性策略（并行计算似乎更好）：深入理解Java8和Java9中的拆分器特性

Stream.of(1L, 2L, 3L);                     // NON NULL
Stream.of(1L, 2L, 3L).limit(2);            // NULL
Stream.of(1L, 2L, 3L).limit(2).parallel(); // NON NULL

spliterator = Stream.of(1L, 2L, 3L).limit(2).spliterator();
stream = StreamSupport.stream(spliterator, true); // No parallel processing!

在本例中，从禁用拆分功能的顺序流创建了一个拆分器(.trysplit()返回null)。当以后需要转换回一个流时，该流不会从并行处理中受益。一种耻辱。

最大的问题是：作为解决办法，在调用.spliterator()之前总是将流转换为并行流会有什么主要影响？

// Supports activation of parallel processing later
public static <T> Stream<T> myOperation(Stream<T> stream) {
    boolean isParallel = stream.isParallel();
    Spliterator<T> spliterator = stream.parallel().spliterator();
    return StreamSupport.stream(new Spliterator<T>() {
        // My implementation of the interface here (omitted for clarity)
    }, isParallel).onClose(stream::close);
}

// Now I have the option to use parallel processing when needed:
myOperation(stream).skip(1).parallel()...

Answer 1

这不是拆分器的一般属性，而是封装流管道的包装拆分器的一般属性。

当您在一个由拆分器生成且没有链接操作的流上调用spliterator()时，您将得到一个源拆分器，该源拆分器可能支持也可能不支持trysplit，而与流paralle的状态无关。

ArrayList<String> list = new ArrayList<>();
Collections.addAll(list, "foo", "bar", "baz");
Spliterator<String> sp1 = list.spliterator(), sp2=list.stream().spliterator();
// true
System.out.println(sp1.getClass()==sp2.getClass());
// not null
System.out.println(sp2.trySplit());

同样地

Spliterator<String> sp = Stream.of("foo", "bar", "baz").spliterator();
// not null
System.out.println(sp.trySplit());

…

   // @@@ Detect if stateful operations are present or not
   //     If not then can split otherwise cannot

   /**
    * True if this spliterator supports splitting
    */
   final boolean isParallel;

Spliterator<String> sp = Stream.of("foo", "bar", "baz").map(x -> x).spliterator();
// null
System.out.println(sp.trySplit());