java - 将迭代器转换为流并调用并行，转换是否在共享线程池线程上完成？

Question

所以我使用 Guava 的库 Streams.stream(iterator) 方法将迭代器转换为流。然后我在该流上调用并行并执行一些操作。

我想知道迭代器到流的转换是在共享线程池线程上完成还是事先完成。

        Stream<MyItem> myItemStream = Streams.stream(myItemIterator);
        myItem.parallel()...

想知道如果迭代器转换是在共享线程池线程上完成的，这会给我的用例带来线程安全方面的问题。

谢谢!

Answer 1

对 Streams.stream(Iterator) 的调用只是围绕调用 java StreamSupport 类的便捷方法:

public static <T> Stream<T> stream(Iterator<T> iterator) {
  return StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, 0), false);
}

因此 Stream 将使用通用的 ForkJoinPool。