Java Stream并行流默认使用ForkJoinPool.commonPool()导致任务干扰，必须通过自定义ForkJoinPool.invoke()执行封装的ForkJoinTask来实现真正隔离，因Stream接口未提供setPool等线程池配置方法。
Java Stream API 的并行流默认使用公共的 ForkJoinPool.commonPool()，这会导致不同业务的并行任务相互干扰、线程争用，甚至因某个慢任务拖垮整个应用。要真正隔离任务，必须绕过默认池，用自定义 ForkJoinPool 驱动并行流——但注意：Stream 本身不提供直接设置线程池的 API，需通过反射或封装执行逻辑实现。
为什么不能直接 setPool 或 withForkJoinPool？
Stream 接口没有暴露线程池配置方法。调用 stream.parallel() 后，底层始终委托给 ForkJoinPool.commonPool() 执行。即使你创建了自定义池，Stream 也不会自动使用它——这是设计使然，不是遗漏。
核心方案：用自定义 ForkJoinPool.invoke() 执行并行流逻辑
把并行流操作封装成 ForkJoinTask（如 RecursiveAction），再提交到自定义池中执行。这是最可靠、无副作用的方式：
- 创建专用池：例如
new ForkJoinPool(4, ForkJoinPool.defaultForkJoinWorkerThreadFactory, null, false)（false 表示非异步模式，更贴近普通并行流语义） - 将流处理逻辑包装为
ForkJoinTask：避免直接调用stream.parallel().forEach(...)，改用pool.invoke(task) - 任务内执行串行流 + 显式分片：若数据量大，可先用
Arrays.asList(data).spliterator()分割，再在 task 中递归处理子段
替代方案：用 parallelStream() + 自定义 Spliterator（轻量级隔离）
如果只是想避免 commonPool 拥塞，又不想写完整 ForkJoinTask，可借助 Spliterator 和 StreamSupport.stream() 构建“伪并行流”：
立即学习“Java免费学习笔记（深入）”；
- 基于原始集合构造
Spliterator，设置characteristics()包含Spliterator.CONCURRENT或ORDERED - 用
StreamSupport.stream(spliterator, true)创建并行流（第二个参数为true） - 关键点：该流仍走 commonPool，但可通过
ForkJoinPool.managedBlock()在任务内部主动让出 worker 线程，配合自定义池做协作式调度
不推荐但常见的误区：修改 commonPool 并发度
有人尝试通过 System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "2") 调整公共池大小——这会影响所有使用 commonPool 的地方（包括 CompletableFuture、Arrays.parallelSort 等），属于全局污染，无法按业务隔离。
真正隔离靠的是执行上下文的显式控制，而不是配置共享资源。自定义 ForkJoinPool + invoke 是目前最清晰、可控的做法，虽多几行代码，但边界明确、可监控、可关闭。
