java8 的 stream 和 parallStream 原来求解

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

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

这是一个创建于 2025 天前的主题，其中的信息可能已经有所发展或是发生改变。

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

是这样的吗？

stream

parallstream

串行流

创建

4 条回复 • 2019-06-14 14:18:39 +08:00

yidinghe

2019-06-14 11:17:06 +08:00

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

mazai

2019-06-14 11:25:58 +08:00

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

youngsterxyf

2019-06-14 12:52:48 +08:00

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

lanping

2019-06-14 14:18:39 +08:00

感谢指点