当前位置: 首页 > backend >正文

Java Lambda 表达式与 Stream API 全解析:从基础到进阶

以下是对您博客内容的优化版本,在保留原有核心内容的基础上,补充了Lambda表达式及Stream API的完整方法体系,并通过结构化排版和扩展说明提升可读性。

Java Lambda表达式与Stream API全解析:从基础到进阶

一、Lambda表达式与Stream API基础

Lambda表达式是Java 8引入的函数式编程特性,配合Stream API可高效处理集合数据。其核心优势在于:

  • 减少冗余代码,提升可读性
  • 支持并行处理,优化性能
  • 链式调用实现流式数据处理
二、Stream API核心方法详解

以下以Student类为例(类定义同原博客),展示Stream API的完整方法体系:

1. 数据转换(Map系列)

作用:将流中元素转换为新类型。

// 基础map:转换元素类型
List<Integer> ages = students.stream().map(Student::getAge)  // 提取年龄,返回Stream<Integer>.collect(Collectors.toList());  // [18, 26, 30, 10, 10]// 特化map:返回基本类型流
IntStream ageStream = students.stream().mapToInt(Student::getAge);  // 直接返回IntStream,避免装箱开销// flatMap:合并多层流(处理嵌套集合)
List<Integer> allScores = students.stream().flatMap(student -> student.getCourses().stream())  // 将每个学生的课程流合并为一个流.collect(Collectors.toList());  // 假设getCourses()返回List<Integer>

注意map处理单个元素转换,flatMap处理多层集合展开(如将Stream<List<T>>转为Stream<T>)。

2. 数据过滤与去重

filter:按条件筛选元素。

List<Student> adultStudents = students.stream().filter(student -> student.getAge() > 18)  // 保留年龄>18的学生.collect(Collectors.toList());

distinct:根据元素equalshashCode去重。

List<Student> uniqueStudents = students.stream().distinct()  // 去重,需Student重写equals和hashCode.collect(Collectors.toList());

3. 排序与限制

sorted:排序(支持自定义比较器)。

// 自然排序(年龄升序)
List<Integer> sortedAges = students.stream().map(Student::getAge).sorted()  // 等价于sorted(Comparator.naturalOrder()).collect(Collectors.toList());  // [10, 10, 18, 26, 30]// 自定义排序(年龄降序)
List<Student> sortedStudents = students.stream().sorted((s1, s2) -> s2.getAge() - s1.getAge()).collect(Collectors.toList());

limit/skip:限制流长度(limit取前n个,skip跳过前n个)。

List<Student> firstTwo = students.stream().limit(2)  // 取前2个学生.collect(Collectors.toList());

4. 聚合与归约(Reduce)

reduce:将流中元素聚合为单个结果。

// 计算年龄总和
int totalAge = students.stream().mapToInt(Student::getAge).sum();  // 更简洁的归约方式,等价于:// .reduce(0, (sum, age) -> sum + age);// 复杂归约:找出年龄最大的学生
Student oldestStudent = students.stream().reduce((s1, s2) -> s1.getAge() > s2.getAge() ? s1 : s2).orElse(null);

5. 查找与匹配

findFirst/findAny:查找第一个/任意元素(并行流中findAny效率更高)。

int firstAdultAge = students.stream().filter(s -> s.getAge() > 18).findFirst().map(Student::getAge).orElse(0);  // 若无可选元素,返回0

allMatch/anyMatch/noneMatch:判断流中元素是否满足条件。

boolean hasTeenager = students.stream().anyMatch(s -> s.getAge() < 20);  // 是否有青少年

6. 消费与调试(Peek)

peek:对流中元素执行操作(常用于调试)。

List<Student> debugList = students.stream().peek(s -> System.out.println("处理学生:" + s.getName())).collect(Collectors.toList());

7. 其他实用方法

count:统计元素数量。

long studentCount = students.stream().count();

collect:将流转换为集合/Map等(配合Collectors工具类)。

// 按年龄分组
Map<Integer, List<Student>> studentsByAge = students.stream().collect(Collectors.groupingBy(Student::getAge));// 提取姓名列表
List<String> names = students.stream().map(Student::getName).collect(Collectors.toList());

三、Lambda表达式进阶用法

1. 方法引用(Method Reference)

简化Lambda表达式,直接引用已有方法。

// 等价于 x -> x.getAge()
students.stream().map(Student::getAge);// 静态方法引用
List<String> names = students.stream().map(Student::getName).collect(Collectors.toList());
2. 构造器引用
// 将Integer列表转为Student对象列表(假设Student有Integer参数的构造器)
List<Student> studentList = ages.stream().map(Student::new)  // 等价于 x -> new Student(x).collect(Collectors.toList());

四、性能优化与注意事项

  1. 惰性求值:Stream操作分为惰性(filter/map)和及早(collect/reduce),需调用及早操作才会执行。
  2. 并行流:大数据量时使用parallelStream()提升性能,但需注意线程安全。
  3. 装箱开销:使用mapToInt/mapToLong等特化方法避免自动装箱。

五、完整示例:综合应用

// 需求:统计年龄>20的学生姓名,按年龄降序排列,取前3个
List<String> result = students.stream().filter(s -> s.getAge() > 20)       // 过滤年龄>20.sorted((s1, s2) -> s2.getAge() - s1.getAge())  // 年龄降序.limit(3)                           // 取前3个.map(Student::getName)              // 提取姓名.collect(Collectors.toList());      // 转换为列表

通过以上优化,内容覆盖了Lambda与Stream API的核心方法,并补充了进阶用法和性能建议,结构更清晰,示例更全面。如需进一步扩展,可加入并行流对比、自定义Collector实现等深度内容。

http://www.xdnf.cn/news/13823.html

相关文章:

  • 短剧小程序开发:开启碎片化娱乐新视界
  • 第 4 篇:线性回归——机器学习“开山第一斧”,用一条直线洞见AI本质
  • 机器学习-黑马笔记
  • Redis缓存三大难题:穿透、击穿、雪崩
  • 名称 深度学习(监督学习) Iteration 一次 mini-batch 前向+反向传播更新 Epoch 所有数据集训练一遍。这两个概念不一样吗?
  • openEuler 虚拟机中 Shell 脚本实现自动化备份与清理实践
  • (十四)上市企业(协会)实施IPD成功案例分享之——美国建筑师协会AIA
  • MS1824+MS7210 AV/S-Video/VGA/YPbPr/RGB888/BT601、656/BT1120转HD转换器
  • tvm开源程序是适用于 CPU、GPU 和专用加速器的开放式深度学习编译器堆栈
  • window 显示驱动开发-处理视频帧
  • Lua 的闭包(closure)特性
  • 每日Prompt:宫崎骏风格插画
  • mapbox高阶,使用mbview发布mbtiles数据为矢量切片服务,并加载
  • 《TCP/IP协议卷1》 ARPICMP协议
  • Eureka 心跳续约机制
  • 【消息队列】——如何实现消息保序
  • Java 序列化与反序列化:对象的持久化——从原理到实战的深度解析
  • 开源PSS解析器
  • 深度学习简介
  • 【驱动设计的硬件基础】处理器的分类
  • Opencv 相机标定相关API及原理介绍
  • 按7:2:1比例随机划分yolo数据集
  • 2025.uexp、.uasset文件、.ubulk如何打开
  • Flutter 命名路由与参数传递完全指南
  • 机器学习×第七卷:正则化与过拟合——她开始学会收敛,不再贴得太满
  • 【unitrix】 1.3 Cargo.toml 文件解析
  • 软考-计算机硬件组成
  • reactor模型
  • 支持 CHI 协议的 NOC的错误注入和边界条件测试
  • Kubernetes微服务发布治理与Java容器化终极实践指南