0

0

Java常用类库中的Stream操作与Stream API

P粉602998670

P粉602998670

发布时间:2026-01-06 13:51:08

|

449人浏览过

|

来源于php中文网

原创

java stream是一次性不可重用的计算管道,消费后抛illegalstateexception;需每次重新创建或转为集合复用,parallelstream慎用于小数据或含i/o场景,collect操作需注意null与线程安全问题。

java常用类库中的stream操作与stream api

Java 的 Stream 不是集合,也不是数据结构,它是一次性、不可重用的计算管道——用错一次,后续调用 forEachcollect 就会抛 IllegalStateException: stream has already been operated upon or closed

Stream 一旦消费就关闭,不能重复使用

很多人把 Stream 当成 List 那样反复遍历,结果在第二次 collect()count() 时直接报错。这不是 bug,是设计使然:中间操作(如 filtermap)不执行,终端操作(如 collectfindFirstforEach)才触发流水线并消耗流。

  • 错误写法:
    Stream<String> stream = list.stream().filter(s -> s.length() > 3);
    List<String> a = stream.collect(Collectors.toList());
    List<String> b = stream.collect(Collectors.toList()); // 报 IllegalStateException
  • 正确做法:每次需要新流,就重新调用 list.stream();或先转为集合再复用:List<string> filtered = list.stream().filter(...).collect(Collectors.toList());</string>
  • 如果必须“多次消费”,说明你其实不需要 Stream ——该用 Collection 或数组

parallelStream() 并不总是更快,尤其小数据量或含 I/O

parallelStream() 底层用的是 ForkJoinPool.commonPool(),启动开销、任务拆分、结果合并都有成本。对几千以内元素的简单 CPU 计算,串行反而更稳更快;若操作中含同步块、System.out.println、文件读写等阻塞行为,还可能引发线程竞争或死锁。

  • 适合场景:纯 CPU 密集型、数据量 ≥ 10⁴、无共享状态、无外部依赖的操作(如数值聚合、字符串批量处理)
  • 慎用场景:含 synchronizedThreadLocal、数据库连接、日志输出、Random 实例(非线程安全)
  • 可临时切换:用 stream.parallel().sequential() 强制切回串行调试,但注意这不重置流状态

collect() 的三种常用形式与陷阱

collect() 是最易出错的终端操作之一,尤其混淆 Collectors.toList()Collectors.toCollection(ArrayList::new) 的语义差异,或误用 toMap 导致 NullPointerException

VIVA
VIVA

一个免费的AI创意视觉设计平台

下载

立即学习Java免费学习笔记(深入)”;

  • Collectors.toList() 返回的是不可保证具体类型的 List(JDK 16+ 是 ArrayList,但规范不保证),且不保证线程安全;并发流中用它可能产生未定义行为
  • toMap(keyMapper, valueMapper) 要求 key 不能为 null,否则抛 NullPointerException;遇到重复 key 默认失败,需显式传第三个参数 BinaryOperator 处理冲突(如 (a,b) -> a
  • 想收集到 LinkedHashSet 去重保序?别用 toSet()(不保序),改用:
    stream.collect(Collectors.toCollection(LinkedHashSet::new))

filter + map 组合时 null 值的隐性丢失

map 中返回 null,再接 filter(Objects::nonNull) 看似能兜底,但其实没用——map 本身不会过滤,它只是把元素转成 null,而后续 filter 才负责筛掉这些 null。真正危险的是:某些自定义 map 函数未判空,导致 NullPointerException 直接中断流。

  • 安全写法示例(避免 NPE):
    list.stream()
        .filter(Objects::nonNull)
        .map(s -> s.toUpperCase(Locale.ROOT))
        .filter(Objects::nonNull)
  • 更推荐提前防御:用 Optional 包装映射逻辑,或用 mapMulti(JDK 16+)替代复杂转换
  • 注意 flatMap 返回空 Stream.empty() 是合法的,等价于“跳过该元素”,不是 null

Stream 的核心价值不在语法糖,而在声明式表达“做什么”,而非“怎么做”。但它的不可变性、一次性、延迟执行特性,和集合类完全不同。写完一段 Stream 流水线,先问自己:这个流会不会被意外复用?里面有没有隐藏的副作用?终端操作是否真的只执行一次?这些问题比学会十个 Collectors 更关键。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1010

2023.08.02

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

254

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

1089

2024.03.01

counta和count的区别
counta和count的区别

Count函数用于计算指定范围内数字的个数,而CountA函数用于计算指定范围内非空单元格的个数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

203

2023.11.20

php中foreach用法
php中foreach用法

本专题整合了php中foreach用法的相关介绍,阅读专题下面的文章了解更多详细教程。

266

2025.12.04

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

760

2023.08.03

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

221

2023.09.04

java基础知识汇总
java基础知识汇总

java基础知识有Java的历史和特点、Java的开发环境、Java的基本数据类型、变量和常量、运算符和表达式、控制语句、数组和字符串等等知识点。想要知道更多关于java基础知识的朋友,请阅读本专题下面的的有关文章,欢迎大家来php中文网学习。

1566

2023.10.24

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.1万人学习

Java 教程
Java 教程

共578课时 | 80.6万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号