有两个不同方面。
首先，只有一个流水线是顺序的或并行的。在内流处选择顺序还是并行无关紧要。请注意，
downstream您在引用的代码片段中看到的使用者代表整个后续流管道，因此在您的代码中（以结尾）
.collect(Collectors.toSet());，该使用者最终会将结果元素添加到
Set不是线程安全的单个实例中。因此，与单个使用者并行处理内部流将破坏整个操作。
如果外部流被拆分，则引用的代码可能会与添加到不同集合的不同使用者同时调用。这些调用中的每个调用都会处理外部流的不同元素，以映射到不同的内部流实例。由于您的外部流仅包含一个元素，因此无法拆分。
这已经实现了，这也是为什么flatMap（）之后的filter（）在Java流中“不完全”惰性的原因？问题，如
forEach内部流所称，它将把所有元素传递给下游使用者。如该答案所示，支持懒惰和子流拆分的替代实现是可能的。但这是实现它的根本不同的方法。Stream实现的当前设计主要根据使用者组成来工作，因此最后，源拆分器（以及从中拆分的源拆分器）
Consumer在
tryAdvance或中接收代表整个流管道的
forEachRemaining。相比之下，链接答案的解决方案确实进行了分隔器组合，从而产生了新的
Spliterator委托给源分割器。我以为，这两种方法都有优势，而且我不确定在相反方向工作时OpenJDK实现会损失多少。
