JDK8---Stream流详解

Stream流

  • 一.概述
  • 二.数据准备
  • 二.Stream流的创建
    • 2.1 单列集合创建Stream流.
    • 2.2 数组创建Stream流
    • 2.3 双列集合创建Stream流
  • 三. 中间操作.
    • 3.1 filter(过滤操作)
    • 3.2 map(计算或者转换)
    • 3.3 distinct(去重操作)
    • 3.4 sorted(排序操作)
    • 3.5 limit (设置流的长度)
    • 3.6 skip(跳过前n个元素)
    • 3.7 flatMap(一个对象转为多个对象)
  • 四.终结操作
    • 4.1 forEach(遍历流中的每一个元素)
    • 4.2 count(获取流中元素的个数)
    • 4.3 max和min(获取流中的最大值或最小值)
    • 4.4 collection(把当前流转化为一个集合) ==最常用==
    • 4.5 anyMatch(任一匹配)
    • 4.6 allMatch(都符合条件)
    • 4.7 noneMatch(都不符合条件)
    • 4.8 findAny(获取任意一个元素)
    • 4.9 findFirst(获取流中的第一个元素)

一.概述

  • 在 Java 中，Stream 是一个来自java.util.stream包的接口，用于对集合（如List、Set等）或数组等数据源进行操作的一种抽象层。它可以让你以一种声明式的方式处理数据，更专注于 “做什么” 而不是 “怎么做”。简单来说，Stream 就像是一条数据的管道，数据在这个管道中流动，并且可以在流动的过程中被各种操作修改。
  • 对Stream流的操作可以分为三种:
    1. 创建流: 可以由数组或者集合创建.
    2. 中间操作: 每次返回一个新的流，可以有多个中间操作
    3. 终结操作: 每个流只能进行一次终端操作，终端操作结束后流无法再次使用。终端操作会产生一个新的集合.
  • Stream流的特性:
    • 惰性求值（Lazy Evaluation）：Stream流的中间操作（如filter、map、sorted等）是惰性求值的。这意味着当你定义了一系列中间操作时，这些操作并不会立即执行。只有当遇到终端操作（如forEach、reduce、collect等）时，整个操作链才会被触发执行。
    • 不可变（Immutability）: Stream 本身是不可变的。这意味着一旦一个 Stream 对象被创建，你不能修改它。每一个中间操作都会返回一个新的 Stream 对象，而不是在原始的 Stream 上进行修改。
    • 管道化（Pipelining）: Stream 操作可以像管道一样串联起来。一个操作的输出可以作为下一个操作的输入，从而可以对数据进行连续的处理。这种管道化的方式使得代码更加紧凑和易读，并且能够高效地处理数据。
    • 内部迭代（Internal Iteration）: 与传统的外部迭代（如使用for循环）不同，Stream 采用内部迭代。在传统的外部迭代中，你需要手动控制迭代的过程，例如，在一个for循环中，你要明确地指定循环的起始、结束条件和每次迭代的步长。而在 Stream 中，迭代的过程是由 Stream 库内部管理的，你只需要指定要对数据进行什么操作（通过中间操作和终端操作）。
    • 支持多种数据源和数据类型:
      • 数据源多样性：Stream 可以从各种数据源创建，如集合（List、Set、Map等）、数组、I/O 通道等。这使得它可以广泛地应用于不同的数据处理场景。
      • 数据类型多样性：它可以处理各种数据类型，包括基本数据类型（通过IntStream、LongStream、DoubleStream等专门的流）和引用数据类型。例如，可以创建一个IntStream来处理整数数组，也可以创建一个Stream<String>来处理字符串列表。

二.数据准备

@Data
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode//用于后期的去重使用
public class Author {//idprivate Long id;//姓名private String name;//年龄private Integer age;//简介private String intro;//作品private List<Book> books;
}

@Data
@AllArgsConstructor
@NoArgsConstructor
@EqualsAndHashCode//用于后期的去重使用
public class Book {//idprivate Long id;//书名private String name;//分类private String category;//评分private Integer score;//简介private String intro;}

private static List<Author> getAuthors() {//数据初始化Author author = new Author(1L,"蒙多",33,"一个从菜刀中明悟哲理的祖安人",null);Author author2 = new Author(2L,"亚拉索",15,"狂风也追逐不上他的思考速度",null);Author author3 = new Author(3L,"易",14,"是这个世界在限制他的思维",null);Author author4 = new Author(3L,"易",14,"是这个世界在限制他的思维",null);//书籍列表List<Book> books1 = new ArrayList<>();List<Book> books2 = new ArrayList<>();List<Book> books3 = new ArrayList<>();books1.add(new Book(1L,"刀的两侧是光明与黑暗","哲学,爱情",88,"用一把刀划分了爱恨"));books1.add(new Book(2L,"一个人不能死在同一把刀下","个人成长,爱情",99,"讲述如何从失败中明悟真理"));books2.add(new Book(3L,"那风吹不到的地方","哲学",85,"带你用思维去领略世界的尽头"));books2.add(new Book(3L,"那风吹不到的地方","哲学",85,"带你用思维去领略世界的尽头"));books2.add(new Book(4L,"吹或不吹","爱情,个人传记",56,"一个哲学家的恋爱观注定很难把他所在的时代理解"));books3.add(new Book(5L,"你的剑就是我的剑","爱情",56,"无法想象一个武者能对他的伴侣这么的宽容"));books3.add(new Book(6L,"风与剑","个人传记",100,"两个哲学家灵魂和肉体的碰撞会激起怎么样的火花呢？"));books3.add(new Book(6L,"风与剑","个人传记",100,"两个哲学家灵魂和肉体的碰撞会激起怎么样的火花呢？"));author.setBooks(books1);author2.setBooks(books2);author3.setBooks(books3);author4.setBooks(books3);List<Author> authorList = new ArrayList<>(Arrays.asList(author,author2,author3,author4));return authorList;}

二.Stream流的创建

2.1 单列集合创建Stream流.

		List<Author> authors = getAuthors();Stream<Author> stream = authors.stream();

2.2 数组创建Stream流

  • Arrays.stream(数组) 或者使用Stream.of来创建
		Integer[] arr = {1,2,3,4,5};Stream<Integer> stream = Arrays.stream(arr);Stream<Integer> stream2 = Stream.of(arr);

2.3 双列集合创建Stream流

  • 转换成单列集合后再创建
		Map<String,Integer> map = new HashMap<>();map.put("蜡笔小新",19);map.put("黑子",17);map.put("日向翔阳",16);Stream<Map.Entry<String, Integer>> stream = map.entrySet().stream();

三. 中间操作.

3.1 filter(过滤操作)

  • 可以对流中的元素进行条件过滤，符合过滤条件的才能继续留在流中。
  • 打印所有姓名长度大于1的作家的姓名.
		List<Author> authors = getAuthors();authors.stream().filter(author -> author.getName().length()>1).forEach(author -> System.out.println(author.getName()));

在这里插入图片描述
在这里插入图片描述

3.2 map(计算或者转换)

打印所有作家的姓名

		List<Author> authors = getAuthors();authors.stream().map(author -> author.getName()).forEach(name->System.out.println(name));

在这里插入图片描述

3.3 distinct(去重操作)

  • 打印所有作家的姓名，并且要求其中不能有重复元素。
		List<Author> authors = getAuthors();authors.stream().distinct().forEach(author -> System.out.println(author.getName()));

在这里插入图片描述

注意：distinct方法是依赖Object的equals方法来判断是否是相同对象的。所以需要注意重写equals方法。

3.4 sorted(排序操作)

  • 对流中的元素按照年龄进行降序排序，并且要求不能有重复的元素。
		 List<Author> authors = getAuthors();// 对流中的元素按照年龄进行降序排序，并且要求不能有重复的元素。authors.stream().distinct().sorted((o1, o2) -> o2.getAge()-o1.getAge()).forEach(author -> System.out.println(author.getAge()));

在这里插入图片描述

3.5 limit (设置流的长度)

  • 对流中的元素按照年龄进行降序排序，并且要求不能有重复的元素,然后打印其中年龄最大的两个作家的姓名。
		List<Author> authors = getAuthors();authors.stream().distinct().sorted().limit(2).forEach(author -> System.out.println(author.getName()));

在这里插入图片描述

3.6 skip(跳过前n个元素)

  • 打印除了年龄最大的作家外的其他作家，要求不能有重复元素，并且按照年龄降序排序。
 		//打印除了年龄最大的作家外的其他作家，要求不能有重复元素，并且按照年龄降序排序。List<Author> authors = getAuthors();authors.stream().distinct().sorted().skip(1).forEach(author -> System.out.println(author.getName()));

在这里插入图片描述

3.7 flatMap(一个对象转为多个对象)

  • 打印所有书籍的名字。要求对重复的元素进行去重。
//        打印所有书籍的名字。要求对重复的元素进行去重。List<Author> authors = getAuthors();authors.stream().flatMap(author -> author.getBooks().stream()).distinct().forEach(book -> System.out.println(book.getName()));

在这里插入图片描述

四.终结操作

4.1 forEach(遍历流中的每一个元素)

  • 输出所有作家的名字
		//        输出所有作家的名字List<Author> authors = getAuthors();authors.stream().map(author -> author.getName()).distinct().forEach(name-> System.out.println(name));

4.2 count(获取流中元素的个数)

  • 打印这些作家的所出书籍的数目，注意删除重复元素。
		//打印这些作家的所出书籍的数目，注意删除重复元素。List<Author> authors = getAuthors();long count = authors.stream().flatMap(author -> author.getBooks().stream()).distinct().count();System.out.println(count);

4.3 max和min(获取流中的最大值或最小值)

  • 分别获取这些作家的所出书籍的最高分和最低分并打印。
//        分别获取这些作家的所出书籍的最高分和最低分并打印。//Stream<Author>  -> Stream<Book> ->Stream<Integer>  ->求值List<Author> authors = getAuthors();Optional<Integer> max = authors.stream().flatMap(author -> author.getBooks().stream()).map(book -> book.getScore()).max((score1, score2) -> score1 - score2);Optional<Integer> min = authors.stream().flatMap(author -> author.getBooks().stream()).map(book -> book.getScore()).min((score1, score2) -> score1 - score2);System.out.println(max.get());System.out.println(min.get());

4.4 collection(把当前流转化为一个集合) 最常用

  • 获取一个存放所有作者名字的List集合。
//        获取一个存放所有作者名字的List集合。List<Author> authors = getAuthors();List<String> nameList = authors.stream().map(author -> author.getName()).collect(Collectors.toList());System.out.println(nameList);
  • 获取一个所有书名的Set集合。
//        获取一个所有书名的Set集合。List<Author> authors = getAuthors();Set<Book> books = authors.stream().flatMap(author -> author.getBooks().stream()).collect(Collectors.toSet());System.out.println(books);
  • 获取一个Map集合，map的key为作者名，value为List
//        获取一个Map集合，map的key为作者名，value为List<Book>List<Author> authors = getAuthors();Map<String, List<Book>> map = authors.stream().distinct().collect(Collectors.toMap(author -> author.getName(), author -> author.getBooks()));System.out.println(map);

4.5 anyMatch(任一匹配)

  • 判断是否有年龄在29以上的作家
//        判断是否有年龄在29以上的作家List<Author> authors = getAuthors();boolean flag = authors.stream().anyMatch(author -> author.getAge() > 29);System.out.println(flag);

4.6 allMatch(都符合条件)

  • 判断是否所有的作家都是成年人
//        判断是否所有的作家都是成年人List<Author> authors = getAuthors();boolean flag = authors.stream().allMatch(author -> author.getAge() >= 18);System.out.println(flag);

4.7 noneMatch(都不符合条件)

  • 判断作家是否都没有超过100岁的。
//        判断作家是否都没有超过100岁的。List<Author> authors = getAuthors();boolean b = authors.stream().noneMatch(author -> author.getAge() > 100);System.out.println(b);

4.8 findAny(获取任意一个元素)

  • 获取任意一个年龄大于18的作家，如果存在就输出他的名字
//        获取任意一个年龄大于18的作家，如果存在就输出他的名字List<Author> authors = getAuthors();Optional<Author> optionalAuthor = authors.stream().filter(author -> author.getAge()>18).findAny();optionalAuthor.ifPresent(author -> System.out.println(author.getName()));

4.9 findFirst(获取流中的第一个元素)

  • 获取流中的第一个元素。
//        获取一个年龄最小的作家，并输出他的姓名。List<Author> authors = getAuthors();Optional<Author> first = authors.stream().sorted((o1, o2) -> o1.getAge() - o2.getAge()).findFirst();first.ifPresent(author -> System.out.println(author.getName()));

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

tcp shutdown, fin_wait1, fin_wait2, close_wait, last_ack, 谢特！

tcp shutdown, fin_wait1, fin_wait2, close_wait, last_ack, 谢特！

TCP 作为双向传输协议&#xff0c;如果你想只收不发&#xff0c;可以单向关掉发&#xff0c;shutdown(socket.SHUT_WR)&#xff0c;但不建议这么做。 看以下代码&#xff1a; #!/Users/zhaoya/myenv/bin/python3 # client import socketclient_socket socket.socket(socket.…
阅读更多...
算法详解——线段树

算法详解——线段树

1. 线段树介绍 线段树是一个高度平衡二叉树&#xff0c;它主要用来高效动态地管理一个序列。线段树叶子结点存储序列元素值&#xff0c;分支结点存储一个连续地子区间的某种聚合信息&#xff0c;例如最值、均值等信息。 如图所示&#xff1a; 用这样一个树状结构来管理序列…
阅读更多...
XXL-JOB

XXL-JOB

Github 地址&#xff1a; https://github.com/xuxueli/xxl-job/ 。 官⽅介绍&#xff1a; https://www.xuxueli.com/xxl-job/ 。 XXL-JOB 于 2015 年开源&#xff0c;是⼀款优秀的轻量级分布式任务调度框架&#xff0c;⽀持任务可视化管理、弹性 扩容缩容、任务失败重试和告…
阅读更多...
基于 Python 的 Django 框架开发的电影推荐系统

基于 Python 的 Django 框架开发的电影推荐系统

项目简介&#xff1a;本项目是基于 Python 的 Django 框架开发的电影推荐系统&#xff0c;主要功能包括&#xff1a; 电影信息爬取&#xff1a;获取并更新电影数据。数据展示&#xff1a;提供电影数据的列表展示。推荐系统&#xff1a;基于协同过滤算法实现个性化推荐。用户系…
阅读更多...
服务器的免密登录和文件传输

服务器的免密登录和文件传输

在天文学研究中&#xff0c;通常会采用ssh登录服务器&#xff0c;把复杂的计算交给服务器&#xff0c;但是如果你没有进行额外的配置&#xff0c;那么登录服务器&#xff0c;以及和服务器进行文件传输&#xff0c;每次都要输入账号和密码&#xff0c;比较不方便&#xff0c;Win…
阅读更多...
interrupt、interrupted、isInterrupted方法详解

interrupt、interrupted、isInterrupted方法详解

interrupt方法的源码&#xff1a; public void interrupt() {if (this ! Thread.currentThread())checkAccess();synchronized (blockerLock) {Interruptible b blocker;if (b ! null) {interrupt0(); //仅仅对当前线程的中断位进行标记b.interrupt();return;}}interrupt0()…
阅读更多...
yarn 下载安装、下载依赖、通过 vscode 运行服务（Windows11）

yarn 下载安装、下载依赖、通过 vscode 运行服务（Windows11）

目录 yarn工具前置要求&#xff1a;安装node.js并配置好国内镜像源下载安装下载依赖特别的&#xff1a; 启动服务 yarn 工具 系统&#xff1a;Windows 11 前置要求&#xff1a;安装node.js并配置好国内镜像源 参考&#xff1a;本人写的《node.js下载、安装、设置国内镜像源…
阅读更多...
JDK8 Kylin jdk-8u341-linux-x64.tar.gz

JDK8 Kylin jdk-8u341-linux-x64.tar.gz

JDK8 Kylin jdk-8u341-linux-x64.tar.gz chmod 777 jdk-8u341-linux-x64.tar.gz tar -zxvf jdk-8u341-linux-x64.tar.gz chmod 777 -R jdk1.8.0_341 vi /etc/profile ESC :wq source /etc/profile java -version eclipse JRE tomcat
阅读更多...
ssm基于vue框架和elementui组件的手机官网+vue

ssm基于vue框架和elementui组件的手机官网+vue

系统包含&#xff1a;源码论文 所用技术&#xff1a;SpringBootVueSSMMybatisMysql 免费提供给大家参考或者学习&#xff0c;获取源码请私聊我 需要定制请私聊 目 录 目 录 III 1 绪论 1 1.1 研究背景 1 1.2 目的和意义 1 1.3 论文结构安排 2 2 相关技术 3 2.1 SSM框…
阅读更多...
如何封装一个可取消的 HTTP 请求？

如何封装一个可取消的 HTTP 请求？

前言 你可能会好奇什么样的场景会需要取消 HTTP 请求呢&#xff1f; 确实在实际的项目开发中&#xff0c;可能会很少有这样的需求&#xff0c;但是不代表没有&#xff0c;比如&#xff1a; 假如要实现上述这个公告栏&#xff0c;每点击一个 tab 按钮就会切换展示容器容器中…
阅读更多...
关于武汉芯景科技有限公司的马达驱动芯片AT6237开发指南（兼容DRV8837)

关于武汉芯景科技有限公司的马达驱动芯片AT6237开发指南（兼容DRV8837)

一、芯片引脚介绍 1.芯片引脚 二、系统结构图 三、功能描述 逻辑功能
阅读更多...
sqlserver、达梦、mysql调用存储过程（带输入输出参数）

sqlserver、达梦、mysql调用存储过程（带输入输出参数）

1、sqlserver&#xff0c;可以省略输出参数 --sqlserver调用存储过程&#xff0c;有输入参数&#xff0c;有输出参数--省略输出参数 exec proc_GetReportPrintData 1, , , 1--输出参数为 null exec proc_GetReportPrintData 1, , , 1, null--固定输出参数 exec proc_GetReport…
阅读更多...
leetcode 1470.重新排列数组

leetcode 1470.重新排列数组

1.题目要求: 2.题目代码: class Solution { public:vector<int> shuffle(vector<int>& nums, int n) {vector<int> x_array(nums.begin(),nums.begin() n);vector<int> y_array(nums.begin() n,nums.end());int x_index 0;int y_index 0;for…
阅读更多...
各地级市能源消耗量数据-基于灯光数据的反演（2000-2022年）

各地级市能源消耗量数据-基于灯光数据的反演（2000-2022年）

今天带来的数据是的全国各省市能源消耗量数据&#xff0c;省级的能源消耗量数据可以在统计年鉴之中查到&#xff0c;但市级的数据却暂无统计。但今天我们基于一篇论文提供的思路&#xff0c;通过夜间灯光与省级能源消耗量对更小尺度的地区能源消耗量进行反算。原文提供1995-200…
阅读更多...
微服务设计模式 - 重试模式（Retry Pattern）

微服务设计模式 - 重试模式（Retry Pattern）

微服务设计模式 - 重试模式&#xff08;Retry Pattern&#xff09; 定义 重试模式&#xff08;Retry Pattern&#xff09;是一种微服务中的设计模式&#xff0c;用于在临时性失败&#xff08;如网络故障或暂时不可用的服务&#xff09;发生时&#xff0c;自动重新尝试请求&…
阅读更多...
从源码到成品应用：互联网医院系统与在线问诊APP的开发全解析

从源码到成品应用：互联网医院系统与在线问诊APP的开发全解析

今天将全面解析互联网医院系统和在线问诊APP的开发过程&#xff0c;从源码到成品应用&#xff0c;帮助您理解其中的关键技术和实施策略。 一、系统架构设计 互联网医院系统和在线问诊APP的开发首先需要一个合理的系统架构。通常&#xff0c;系统架构分为前端和后端两个部分。…
阅读更多...
简记 Vue3（一）—— setup、ref、reactive、toRefs、toRef

简记 Vue3（一）—— setup、ref、reactive、toRefs、toRef

个人简介 &#x1f440;个人主页&#xff1a; 前端杂货铺 &#x1f64b;‍♂️学习方向&#xff1a; 主攻前端方向&#xff0c;正逐渐往全干发展 &#x1f4c3;个人状态&#xff1a; 研发工程师&#xff0c;现效力于中国工业软件事业 &#x1f680;人生格言&#xff1a; 积跬步…
阅读更多...
ZooKeeper 客户端API操作

ZooKeeper 客户端API操作

文章目录 一、节点信息1、创建节点2、获取子节点并监听节点变化3、判断节点是否存在4、客户端向服务端写入数据写入请求直接发给 Leader 节点写入请求直接发给 follow 节点 二、服务器动态上下线监听1、监听过程2、代码 三、分布式锁1、什么是分布式锁?2、Curator 框架实现分布…
阅读更多...
C++/list

C++/list

目录 1.list的介绍 2.list的使用 2.1list的构造 2.2list iterator的使用 2.3list capacity 2.4list element access 2.5list modifers 2.6list的迭代器失效 3.list的模拟实现 4.list与vector的对比 欢迎 1.list的介绍 list的文档介绍 cplusplus.com/reference/list/li…
阅读更多...
计算机图形学中向量相关知识chuizhi

计算机图形学中向量相关知识chuizhi

一、向量加法 平行四边形法则 两个向量统一起点&#xff0c;构成平行四边形&#xff0c;对角线为向量加和的结果 三角形法则 两个向量尾首相连&#xff0c;从a起点连接到b终点&#xff0c;为向量加法的结果 多向量首尾相连的加法结果为第一个向量的起点到最后一个向量的终点…
阅读更多...
最新文章

Copyright @ 2022~2023