【学习笔记】Java函数式编程03 Stream流-终结操作

书接上回

3.3.3 终结操作

3.3.3.1 forEach

对集合的每一个元素进行处理

接触很多了不赘述

3.3.3.2 count

用来获取当前流中的元素的个数

比如,打印出所有作家的作品的总数

System.out.println(authors.stream().flatMap(author -> author.getBooks().stream()).count());
3.3.3.3 max和min

可以用来流中的最值。

查看源码可以发现这个方法是需要传入参数的

Optional<T> max(Comparator<? super T> comparator);
Optional<T> min(Comparator<? super T> comparator);

Comparator是一个比较器,但是这里的比较器是什么作用呢?其实stream流的球最值和前面的sorted的实现逻辑类似,都是要求先比较排序后再求最值

另外,这个方法的返回值是Optional类型,这个类型后续会再细讲。

所以max和min不用死记,学会sorted就可以满足需要了

3.3.3.4 ⭐️collect

将流当中的元素转换为一个集合(List/Set/Map)。

阅读源码可以发现collect的两个参数都非常复杂,在实际使用中会使用工具类的方法来快速实现

image-20231212172433634

小练习快速上手

1、获取一个所有作者名字的集合List

authors.stream().map(Author::getName).collect(Collectors.toList())

2、获取一个所有书名的集合SET

authors.stream().flatMap(author -> author.getBooks().stream()).map(Book::getName).collect(Collectors.toSet());

顺带一提,由于set的去重作用,所有其实前面提到的“去重“的需求,也可以尝试用collect来实现

3、获取一个map集合,Key为作者名,Value为作品集List

沿用前面的思路,利用Collectors.toMap方法实现,但是转map是需要指定key和v的,研究toMap方法就可以发现:这里确实要求传入两个Function函数式接口,如下

image-20231221102613795

尝试先写一个匿名内部类的原生写法,然后进行简化:

// 获取一个map集合,Key为作者名,Value为作品集List
List<Author> authors = Author.getAuthor(5);
Map<String, List<Book>> map = authors.stream().collect(Collectors.toMap(new Function<Author, String>() {@Overridepublic String apply(Author author) {return author.getName();}}, new Function<Author, List<Book>>() {@Overridepublic List<Book> apply(Author author) {return author.getBooks();}}));System.out.println(map);// 第一次简化
authors.stream().collect(Collectors.toMap(author -> author.getName(), author -> author.getBooks()));// IDEA提供的进一步简化
authors.stream().collect(Collectors.toMap(Author::getName, Author::getBooks));

不难发现,toMap方法就是分别指定key和value就可以实现转map的要求了

4、获取一个map集合,Key为作者名,Value为作者

注意:需求不同,这次是将val作为作者本身的对象,这个其实也是比较常见的需求

Map<String, List<Author>> collect = author.stream().collect(Collectors.groupingBy(new Function<Author, String>() {@Overridepublic String apply(Author author) {return author.getName();}}));// 简化后
author.stream().collect(Collectors.groupingBy(Author::getName));

介绍完简单的终结操作后,接下来还有一些比较复杂的操作。比如需求场景

  • 判断是否有25岁以上的作家?
  • 判断是不是所有作家都刚满18岁?

3.3.4 终结操作之查找与匹配

3.3.4.1 anyMatch

任一元素符合条件,则返回true

3.3.4.2 allMatch

所有符合条件,则返回true

3.3.4.3 nonMatch

所有的元素都不符合条件

(这个不需要硬记,和allMatch互为补集)


3.3.4.4 findAny

image-20231221112305126

这个操作用于获取流中的任意一个元素,注意,这个操作无法保证获取的是第一个元素

3.3.4.5 findFirst

这个操作用于获取流中的第一个元素。

  • 这个终结操作一般需要结合limitsorted使用

补充说明

这两个方法返回的对象是JDK8新增的Optional对象,用于避免空指针等异常的,后续会详细介绍。

  • 要获取里面的对象使用get()方法即可。
  • ifPresent()方法可以在对象存在时,执行方法内的函数

3.3.5 ⭐️终结操作之归并操作-reduce

reduce单词字面意思有减少的意思,可以引申为缩小、裁剪的意思

image-20231226144739020

3.3.5.1 reduce概念

对流中的数据,按照指定的计算方式,计算出一个结果。(缩紧操作)

reduce的作用,将stream中的元素“组合”起来,最终传出组合的结果,起到一个紧缩、简化的作用。

两种实现方式

  • 传入一个初始值,按照给定的计算方式以此与流中的每个元素进行“计算”,每次计算得到的结果都可以和后面的元素再进行计算,并最终给出结果。
  • 没有初始值,而是将第一个元素给定为初始值,然后以此和流内的其他元素进行“计算”并给出结果。

两种方式对应reduce的两种重写方式

  • T reduce(T identity, BinaryOperator<T> accumulator);
  • Optional<T> reduce(BinaryOperator<T> accumulator);
3.3.5.2 reduce有初始值的重写

T reduce(T identity, BinaryOperator<T> accumulator);

查看源码注释可以发现,双参数的实现逻辑如下:

T result = identity;  
for (T element : this stream)      result = accumulator.apply(result, element)  return result;

做两个求最值的快速练习——求出所有作家的最大年纪

List<Author> authors = Author.getAuthor();
// 先打印出每个作家的年纪
authors.stream().map(Author::getAge).sorted().forEach(System.out::println);
System.out.println("-----------------");
// 求最大值 匿名内部类写法
Integer max = authors.stream().map(Author::getAge).reduce(Integer.MIN_VALUE, new BinaryOperator<Integer>() {@Overridepublic Integer apply(Integer element, Integer next) {return element < next ? next : element;}});
System.out.println(max);
// 求最大值 lambda简化
Integer max1 = authors.stream().map(Author::getAge).reduce(Integer.MIN_VALUE, (element, next) -> element < next ? next : element);
System.out.println(max1);

顺带一提前面学到的max()和min()底层就是使用reduce实现的

3.3.5.3 reduce无初始值的调用

Optional<T> reduce(BinaryOperator<T> accumulator);

实现低层逻辑是这样的:

boolean foundAny = false;  
T result = null;  
for (T element : this stream) {      if (!foundAny) {          foundAny = true;         result = element;      }     else          result = accumulator.apply(result, element);  
}  
return foundAny ? Optional.of(result) : Optional.empty();

逻辑就是:

  • 第一个元素给定为初始值,然后以此和流内的其他元素进行“计算”并给出结果。
  • 由于如果流为空返回的对象可能为空,所有这里使用了Optional进行包装

做个练习,一样是求最大年纪

// 匿名内部类原生写法
Optional<Integer> optional = authors.stream().map(Author::getAge).reduce(new BinaryOperator<Integer>() {@Overridepublic Integer apply(Integer element, Integer next) {return element < next ? next : element;}});
//  lambda简化
Optional<Integer> optional1 = authors.stream().map(Author::getAge).reduce((element, next) -> element < next ? next : element);
optional.ifPresent(System.out::println);
optional1.ifPresent(System.out::println);

3.4 Stream流的注意事项

  • 惰性求值
  • 一次性流
  • 不会影响原数据

3.4.1 惰性求值

没有任何终结操作,前面的中间操作都不会得到执行和保留。

  • 实际开发过程中,由于没有终结操作的stream写法并不会编译报错
  • 所以在写代码的时候一定要养成添加终结操作的习惯)

3.4.2 流是一次性的

在进行终结操作后,流会失效(报废。

举个例子:

在这里插入图片描述

  • 在实际开发过程中,使用stream流应该在调用stream()方法后就使用链式编程直到终结操作
  • 如果需要再次操作,就重新调用并生成新的流即可

3.4.3 不会影响原数据

特指是正常操作,而且这也是选择stream流所期望的。

举个例子,在map操作中将年龄+10,其实集合中元素的年龄是不会变化的。

image-20231226161532252

  • 在实际开发中,如果是需要对集合的元素进行操作时,则不建议使用stream流
  • 使用了stream流也应该尽量避免对集合中的元素进行操作(增删改)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/579594.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux安装Python3.12.0

我们这里按照最新的Python3.12.0为示例 下载源文件。 wget https://www.python.org/ftp/python/3.12.0/Python-3.12.0.tgz解压。 tar -zxvf Python-3.12.0.tgz进入文件夹。 cd Python-3.12.0指定安装目录。 ./configure --prefix/usr/local/python3.12/编译&#xff0c;把…

文献研读|Prompt窃取与保护综述

本文介绍与「Prompt窃取与保护」相关的几篇工作。 目录 1. Prompt Stealing Attacks Against Text-to-Image Generation Models&#xff08;PromptStealer&#xff09;2. Hard Prompts Made Easy: Gradient-Based Discrete Optimization for Prompt Tuning and Discovery&#…

汽车零配件装配产线中使用RFID技术和不使用RFID技术的优缺点

汽车零配件装配产线中使用RFID技术和不使用RFID技术的优缺点 RFID(射频识别技术)是非接触式自动识别技术&#xff0c;经常被使用于工业制造、物流管理、仓储物品盘点等领域。我们聊一聊在汽车零配件装配产线中使用和不使用RFID技术的优缺点 在汽车零配件装配线使用RFID技术可以…

Java解决数组的度问题

Java解决数组的度问题 01 题目 给定一个非空且只包含非负数的整数数组 nums&#xff0c;数组的 度 的定义是指数组里任一元素出现频数的最大值。 你的任务是在 nums 中找到与 nums 拥有相同大小的度的最短连续子数组&#xff0c;返回其长度。 示例 1&#xff1a; 输入&…

.NetCore NPOI 读取excel内容及单元格内图片

由于数据方提供的数据在excel文件中不止有文字内容还包含图片信息&#xff0c;于是编写相关测试代码&#xff0c;读取excel文件内容及图片信息. 本文使用的是 NPOI-2.6.2 版本&#xff0c;此版本持.Net4.7.2;.NetStandard2.0;.NetStandard2.1;.Net6.0。 测试文档内容&#xf…

[足式机器人]Part4 南科大高等机器人控制课 CH11 Bascis of Optimization

本文仅供学习使用 本文参考&#xff1a; B站&#xff1a;CLEAR_LAB 笔者带更新-运动学 课程主讲教师&#xff1a; Prof. Wei Zhang 课程链接 &#xff1a; https://www.wzhanglab.site/teaching/mee-5114-advanced-control-for-robotics/ 南科大高等机器人控制课 Ch11 Bascis o…

前端axios与python库requests的区别

当涉及到发送HTTP请求时&#xff0c;Axios和Python中的requests库都是常用的工具。下面是它们的详细说明&#xff1a; Axios&#xff1a; Axios是一个基于Promise的HTTP客户端&#xff0c;主要用于浏览器和Node.js环境中发送HTTP请求。以下是Axios的一些特点和用法&#xff1…

Python获取指定文件夹中的所有文件名脚本

1.获取指定文件夹中的所有文件名 要获取指定文件夹中的所有文件名&#xff0c;您可以使用 os.listdir 函数来列出文件夹中的所有文件和文件夹&#xff0c;然后使用 os.path.isfile 函数来过滤出仅为文件的项。示例代码&#xff1a; import osdef get_file_names(folder_path)…

linux 中 ext2文件系统实现

ext2文件系统结构 图片的svg下载链接&#xff08;图中关于buffer的部分&#xff0c;上下两部分是重复的&#xff0c;是从不同维度下看的buffer结构&#xff09; linux内核本身不提供ext2文件系统的格式化功能&#xff0c;可以参考busybox中对mkfs.ext2的实现&#xff08;mkfs.…

sheng的学习笔记-【中】【吴恩达课后测验】Course 4 -卷积神经网络 - 第二周测验

课程4_第2周_测验题 目录 第一题 1.在典型的卷积神经网络中&#xff0c;随着网络的深度增加&#xff0c;你能看到的现象是&#xff1f; A. 【  】 n H n_H nH​和 n W n_W nW​增加&#xff0c;同时 n C n_C nC​减少 B. 【  】 n H n_H nH​和 n W n_W nW​减少&#x…

【论文笔记】Run, Don’t Walk: Chasing Higher FLOPS for Faster Neural Networks

论文地址&#xff1a;Run, Dont Walk: Chasing Higher FLOPS for Faster Neural Networks 代码地址&#xff1a;https://github.com/jierunchen/fasternet 该论文主要提出了PConv&#xff0c;通过优化FLOPS提出了快速推理模型FasterNet。 在设计神经网络结构的时候&#xff…

性能优化,让用户体验更加完美(渲染层面)

前言 上一篇我们已经围绕“网络层面”探索页面性能优化的方案&#xff0c;接下来本篇围绕“浏览器渲染层面”继续开展探索。正文开始前&#xff0c;我们思考如下问题&#xff1a; 浏览器渲染页面会经过哪几个关键环节&#xff1f;“渲染层面”的优化从哪几方面着手&#xff1f…

初试Kafka

Kafka 是一个分布式流处理平台&#xff0c;通常用作消息中间件&#xff0c;它可以处理大规模的实时数据流。以下是从零开始使用 Kafka 作为消息中间件的基本教程&#xff1a; 步骤 1: 下载和安装 Kafka 访问 Apache Kafka 官方网站&#xff1a;Apache Kafka下载最新的 Kafka …

【Redis】一文掌握Redis原理及常见问题

Redis是基于内存数据库&#xff0c;操作效率高&#xff0c;提供丰富的数据结构&#xff08;Redis底层对数据结构还做了优化&#xff09;&#xff0c;可用作数据库&#xff0c;缓存&#xff0c;消息中间件等。如今广泛用于互联网大厂&#xff0c;面试必考点之一&#xff0c;本文…

2022年山东省职业院校技能大赛高职组云计算赛项试卷第三场-公有云

2022年山东省职业院校技能大赛高职组云计算赛项试卷 目录 2022年职业院校技能大赛高职组云计算赛项试卷 【赛程名称】云计算赛项第三场-公有云 【任务1】公有云服务搭建[10分] 【适用平台】华为云 【题目1】私有网络管理[0.5分] 【题目2】云实例管理[0.5分] 【题目3】数…

什么是 MVVM?

Model–View–ViewModel &#xff08;MVVM&#xff09; 是一个软件架构设计模式&#xff0c;由微软 WPF 和 Silverlight 的架构师 Ken Cooper 和 Ted Peters 开发&#xff0c;是一种简化用户界面的事件驱动编程方式。 由 John Gossman&#xff08;同样也是 WPF 和 Silverlight…

.NET Conf 2023 回顾 – 庆祝社区、创新和 .NET 8 的发布

作者&#xff1a; Jon Galloway - Principal Program Manager, .NET Community Team Mehul Harry - Product Marketing Manager, .NET, Azure Marketing 排版&#xff1a;Alan Wang .NET Conf 2023 是有史以来规模最大的 .NET 会议&#xff0c;来自全球各地的演讲者进行了 100 …

设计模式-注册模式

设计模式专栏 模式介绍模式特点应用场景注册模式和单例模式的区别代码示例Java实现注册模式Python实现注册模式 注册模式在spring中的应用 模式介绍 注册模式是一种设计模式&#xff0c;也称为注册树或注册器模式。这种模式将类的实例化和创建分离开来&#xff0c;避免在应用程…

【广州华锐互动】VR科技科普展厅平台:快速、便捷地创建出属于自己的虚拟展馆

随着科技的不断进步&#xff0c;虚拟现实(VR)技术已经在许多领域取得了显著的成果。尤其是在展馆设计领域&#xff0c;VR科技科普展厅平台已经实现了许多令人瞩目的新突破。 VR科技科普展厅平台是广州华锐互动专门为企业和机构提供虚拟展馆设计和制作的在线平台。通过这个平台&…

Flink on K8S集群搭建及StreamPark平台安装

1.环境准备 1.1 介绍 在使用 Flink&Spark 时发现从编程模型, 启动配置到运维管理都有很多可以抽象共用的地方, 目前streampark提供了一个flink一站式的流处理作业开发管理平台, 从流处理作业开发到上线全生命周期都做了支持, 是一个一站式的流出来计算平台。 未来spark开…