stream只能被消费一次，一旦调用终止操作（如collect、foreach）即失效，再次使用会抛illegalstateexception；安全做法是传数据源或supplier。

直接把一个正在流式处理的 Stream 对象作为参数传递，本身不会出错，但**它会被立即消费或失效，后续无法再使用**——因为 Stream 只能被消费一次。

Stream 一旦开始执行终止操作就不可复用

Stream 的核心规则是：只要调用过一次终止操作（如 collect、forEach、count、reduce 等），该 Stream 就被“关闭”，再次调用任何操作都会抛出 IllegalStateException。

所以，如果你写这样的代码：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

Stream<string> stream = Arrays.asList("a", "b", "c").stream();
process(stream); // 传入方法
stream.forEach(System.out::println); // ❌ 这里会报错
</string>

只要 process() 方法内部对这个 stream 执行了任何终止操作，外面再用就会失败。

中间操作链本身不触发执行，但传递后可能被意外触发

如果接收方只做中间操作（比如 filter、map），那 Stream 还是“活”的，只是返回了一个新 Stream：

void process(Stream<string> s) {
    Stream<string> filtered = s.filter(x -> x.length() > 1); // ✅ 合法，未消费
    System.out.println(filtered.count()); // ❌ 此处 count 是终止操作，stream 已消耗
}
</string></string>

注意：即使你没显式调用终止操作，只要参数在方法内被收集、遍历、计数或转成数组，它就结束了。

常见误用场景

• 重复调用 collect：传入后 collect 一次，外面还想 collect 第二次 → 报错
• 多线程共享同一个 Stream 实例：不仅不可复用，还线程不安全
• 试图缓存并多次使用同一 Stream 引用：比如存在字段里反复调用 → 每次都得重新创建 stream()
• 并行流 + 有状态 lambda：传入后若在 parallelStream 中用了非线程安全操作（如修改外部变量），结果不可预测

安全传递 Stream 的建议

• 传参前确保它尚未被消费，且接收方明确知道只能用一次
• 更推荐传数据源（如 List、数组）而非 Stream，由接收方按需创建 stream() 或 parallelStream()
• 若必须传 Stream，可用 Supplier 包装，每次调用 get() 都新建一个流：

Supplier<stream>> streamSupplier = () -> list.stream();
process(streamSupplier); // 方法内可放心 .get().collect(...)
process(streamSupplier); // 第二次调用仍有效
</stream>

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南