为何末尾调用close()时嵌套流的map、filter操作未被执行

Java Stream 采用惰性求值设计，所有中间操作（例如map、filter）仅会定义处理规则，不会立即执行，只有触发终端操作（例如forEach、collect、count）时，整个流的处理链路才会真正运行。你的代码中内层、外层流都仅定义了中间操作，未添加任何终端操作，因此内部的过滤、处理逻辑完全不会触发，会直接执行到close()方法。

• 你使用map执行写入Map这类副作用操作不符合Stream设计规范，中间操作应当避免无意义的返回值和副作用逻辑，纯遍历处理场景应当使用终端操作forEach而非map。
• 你当前定义的HashMap属于线程不安全类，后续如果切换为并行流，多线程同时写入HashMap会出现数据丢失、容器结构损坏等问题，绝对不能在并行流中使用共享的线程不安全容器存储结果。

并行流场景下应当避免使用共享变量，使用Stream自带的collect终端操作完成结果汇聚，天生支持并行场景下的线程安全，示例代码如下：

import java.util.Objects;
import java.util.stream.Collectors;

// 并行流处理逻辑
Map<String, Long> productModelQuantityReturnedMap = sampleList.parallelStream()
        // 展开内层所有entry
        .flatMap(sampleModel -> sampleModel.getEntries().stream())
        // 过滤orderEntry为null的元素
        .filter(entryModel -> Objects.nonNull(entryModel.getOrderEntry()))
        // 按业务规则生成结果Map
        .collect(Collectors.toMap(
                entryModel -> /* 替换为你的key生成逻辑 */,
                entryModel -> /* 替换为你的value生成逻辑 */,
                // 存在重复key时的合并逻辑，如需累加数量可替换为Long::sum
                (oldVal, newVal) -> newVal
        ));

• 集合生成的Stream不需要手动调用close()方法，只有IO相关的流（比如文件读取生成的Stream）才需要手动释放资源，你的场景下调用close()属于冗余操作。
• 并行流存在线程调度开销，如果你的数据量较小或者单条数据处理逻辑非常轻量，并行流的性能反而可能低于串行流或者普通for循环，建议做完性能测试再决定是否启用并行。

内容的提问来源于stack exchange，提问作者Ayeshmantha Perera