java中Stream的使用流程及注意

Java Stream 使用流程为：先创建数据源，再链式调用惰性求值的中间操作（如filter、map），最后通过终端操作（如collect、forEach）触发计算；Stream不可重复使用，需注意空值处理、线程安全及避免中间操作中执行I/O。

Java 中 Stream 的使用流程其实很清晰：先获取数据源，再链式调用中间操作（如 filter、map），最后执行终端操作（如 collect、forEach）触发计算。关键在于“惰性求值”——中间操作不立即执行，只有终端操作才会真正开始处理数据。

一、Stream 创建的常见方式

Stream 不能直接 new，必须通过已有数据源构建：

• 集合对象调用 stream() 或 parallelStream()（List、Set、Queue 都支持）
• 数组用 Arrays.stream(arr) 或 Stream.of(...)
• 基本类型数组推荐用 IntStream.range()、DoubleStream.of() 等专用流，避免装箱开销
• 生成器方式：Stream.iterate()（需设终止条件）、Stream.generate()（适合无限流，配合 limit 使用）

二、中间操作要注意“不可变性”和“无状态”

filter、map、sorted、distinct、limit、skip 等都是中间操作，返回新 Stream，原数据不受影响。但有两点容易出错：

• 不要在 map/filter 中修改外部变量或原集合，Stream 设计上不保证执行顺序（尤其并行流），可能引发竞态或空指针
• sorted() 默认要求元素实现 Comparable，否则要传 Comparator；若元素为 null，会抛 NullPointerException
• 避免在中间操作里做耗时 I/O 或数据库调用——这违背函数式初衷，也影响性能和可读性

三、终端操作是“开关”，只能执行一次

一旦调用 forEach、collect、count、findFirst、anyMatch 等终端方法，Stream 就关闭了。再次使用会抛 IllegalStateException：

标签： java stream