java8 的 stream 和 parallStream 原来求解

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

This topic created in 2705 days ago, the information mentioned may be changed or developed.

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

是这样的吗？

stream

parallstream

串行流

创建

4 replies • 2019-06-14 14:18:39 +08:00

yidinghe

PRO

Jun 14, 2019

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

mazai

Jun 14, 2019

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

youngsterxyf

Jun 14, 2019

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

lanping

Jun 14, 2019

感谢指点