java8 的 stream 和 parallStream 原来求解

[lanping]

stream 是串行流，parallStream 是并行流，底层实现都是 fork/join
原理是：
1、stream 是创建一个 ForkJoinTask，parallStream 是创建多个 ForkJoinTask
2、stream 和 parallStream 都是采用 ForkJoinPool

是这样的吗？

[yidinghe]

非 parallStream 对集合元素的处理是在当前线程中进行的，没有用到 ForkJoinPool。

[mazai]

只有 并行流用到了 forkjoin 框架 串行并没有 底层是通过传递一个 boolean 变量来区分的

[youngsterxyf]

可以大致读一下 stream 的源码。stream 串行流只是对源数据的迭代器迭代一遍，应用代码中写的算子（多个算子会嵌套调用）。parallelStream 依赖源数据迭代器的切分方式，将源数据尽量均匀地切分成多份，然后基于 forkjoin 框架来并行处理。并行流的成本还是有点高的，所以对于小数据量不要随便使用。

[lanping]

感谢指点