java基础之Java8新特性-Stream(流)

简介

流（Stream）是 Java 8 引入的一种处理集合数据的抽象概念，它提供了一种更简洁、更灵活的方式来操作和处理集合数据。流可以看作是一系列元素的管道，可以对这些元素进行筛选、转换、排序、归约等操作，实现各种数据处理需求。与传统的循环迭代方式相比，流的代码更易读、更易于并行化处理，并且能够充分发挥多核处理器的优势。通过使用流，可以提高代码的可读性和可维护性，同时也能够更高效地处理大规模数据集合。

Stream的常用案例

1.steam将list集合转set集合

public static void main(String [] args){List<Student> students=Arrays.asList(new Student("小明",18),new Student("小黑",16),new Student("小红",17));//转成流并进行set集合转换Set<Student> sets=students.stream().collect(Collectors.toSet());//集合遍历sets.forEach(stu->System.out.println(stu.toString()));}

在上面的示例中，我们首先创建了一个 List 集合 list，包含了三个对象。然后使用 stream 方法将其转换为流，接着使用 collect 方法将流中的元素收集到一个 Set 集合中，使用 Collectors.toSet() 指定要收集到的集合类型。最终得到了一个包含唯一元素的 Set 集合。

注意：转成set集合需要重写实体类Student的equals 方法和 hashCode 方法。

2.steam将list集合转map集合

public static void main(String [] args){List<Student> students=Arrays.asList(new Student("小明",18),new Student("小黑",16),new Student("小红",17));//转成StreamStream<Student> stream=students.stream();//转MapMap<String,Student> map=stream.collect(Collectors.toMap(student->student.getName(), student->student));//遍历map.forEach((key,value)->System.out.println(key+"--"+value));}

在上面的示例中，我们首先创建了一个包含学生对象的 List<Student> 集合 students。然后使用 stream 方法将其转换为流，接着使用 collect 方法将流中的元素收集到一个 Map 集合中，使用 Collectors.toMap() 指定键和值的提取方式。在这里，我们使用学生对象的姓名作为键，学生对象本身作为值。

3.steam计算求和

public static void main(String[] args) {List<Student> students= Arrays.asList(new Student("小明",18),new Student("小黑",16),new Student("小红",17));//创建流并累加年龄int sum=students.stream().mapToInt(Student::getAge).sum();System.out.println(sum);}

4.steam查找最值

  public static void main(String[] args) {List<Student> students= Arrays.asList(new Student("小明",18),new Student("小黑",16),new Student("小红",17));//找出年龄最大的人Optional<Student> max=students.stream().max((o1, o2)->o1.getAge()-o2.getAge());System.out.println(max);//找出年龄最小的人Optional<Student> min=students.stream().min((o1, o2)->o1.getAge()-o2.getAge());System.out.println(min);}

5.stream的match

match 方法用于判断流中的元素是否符合指定的条件，并返回一个布尔值。

match 方法有三个变种：

  1. allMatch 方法：判断流中的所有元素是否都符合指定的条件，如果都符合，返回 true，否则返回 false。

  2. anyMatch 方法：判断流中是否存在任意一个元素符合指定的条件，如果有，返回 true，否则返回 false。

  3. noneMatch 方法：判断流中是否不存在任何一个元素符合指定的条件，如果没有，返回 true，否则返回 false。

 public static void main(String[] args) {List<Student> students= Arrays.asList(new Student("小明",18),new Student("小黑",16),new Student("小红",17));// 判断所有学生年龄是否都大于17boolean match = students.stream().allMatch(s -> s.getAge() > 17);System.out.println(match);//false//判断只要有一个学生年龄小于17boolean match1 = students.stream().anyMatch(s -> s.getAge() < 17);System.out.println(match1);//true//判断没有一个学生年龄大于18boolean match2 = students.stream().noneMatch(s -> s.getAge() > 18);System.out.println(match2);//true}

6.stream过滤器

filter 方法接受一个 Predicate 参数，该参数是一个函数式接口，用于指定过滤条件。filter 方法会根据条件筛选出流中符合条件的元素，并返回一个新的流。

 public static void main(String[] args) {List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);// 过滤并打印出所有偶数Stream<Integer> evenNumbers = numbers.stream().filter(n -> n % 2 == 0);evenNumbers.forEach(System.out::println);}

7.stream Limit和skip

Stream 类提供了 limit 和 skip 方法，用于限制流中元素的数量。

1.limit 方法：该方法用于截取流中的前 n 个元素，并返回一个新的流。如果流中的元素不足 n 个，则返回包含所有元素的流。

 public static void main(String[] args) {List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);// 获取前3个元素Stream<Integer> limitedStream = numbers.stream().limit(3);limitedStream.forEach(System.out::println);}

2.skip 方法：该方法用于跳过流中的前 n 个元素，并返回一个新的流。如果流中的元素不足 n 个，则返回一个空的流。

 public static void main(String[] args) {List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);//跳过前两个元素Stream<Integer> skipStream = numbers.stream().skip(2);skipStream.forEach(System.out::println);}

一般我们会通过limit方法和skip搭配进行分页截取

public static void main(String[] args) {List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5,6,7,8,9,10);//一页五个截取第二页Stream<Integer> skipLimitStream = numbers.stream().skip(5).limit(5);skipLimitStream.forEach(System.out::println);}

8.stream实现排序

 public static void main(String[] args) {// 创建一个包含整数的StreamStream<Integer> stream1 = Stream.of(3, 1, 4, 1, 5, 9);Stream<Integer> stream2 = Stream.of(3, 1, 4, 1, 5, 9);// 使用sorted()方法对Stream1进行升序排序（默认）Stream<Integer> sortedStream = stream1.sorted();sortedStream.forEach(System.out::println);System.out.println("-----------------------------------------------");// 使用sorted()方法对Stream2进行降序排序Stream<Integer> sortedDescStream = stream2.sorted((a, b) -> b.compareTo(a));sortedDescStream.forEach(System.out::println);}

9.组合案例

我们来看一个需求

对给定的学生列表按照年龄降序排列并查找姓张的，获取前3位

public static void main(String[] args) {List<Student> students= Arrays.asList(new Student("张明",18),new Student("李黑",16),new Student("王红",17),new Student("张三",36),new Student("李四",27),new Student("刘备",56),new Student("关羽",47),new Student("张飞",49),new Student("张同",17),new Student("张良",41));//降序排序--查找姓张的--截取前三位students.stream().sorted((s1,s2)->s2.getAge()-s1.getAge()).filter(s->s.getName().startsWith("张")).limit(3).forEach(System.out::println);System.out.println("-----------------------------------------------");}

通过对流进行一系列的中间操作就可以完成这个需求，这种链式调用可以使代码非常简洁。

10.并行流

Stream 类提供了并行流的支持，可以通过 parallel 方法将一个顺序流转换为并行流。并行流可以充分利用多核处理器的优势，将流中的元素进行并发处理，从而提高处理效率。

前面所有流的示例都是顺序流(单线程)，有时在面对较大的数据处理单线程效率太慢，我们就可以使用并行流（多线程）进行优化。

来看一个需求，求1-1亿的累加和，分别用单线程的顺序流跟多线程的并行流来看执行效率。

 public static void main(String[] args) {// 顺序流计算long start = System.currentTimeMillis();int sum = IntStream.rangeClosed(1, 1000000000).sum();long end = System.currentTimeMillis();System.out.println("顺序流计算结果：" + sum + "，耗时：" + (end - start) + " 毫秒");// 并行流计算start = System.currentTimeMillis();sum = IntStream.rangeClosed(1, 1000000000).parallel().sum();end = System.currentTimeMillis();System.out.println("并行流计算结果：" + sum + "，耗时：" + (end - start) + " 毫秒");}

可以看到执行效率还是有明显提升的。

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

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

相关文章

Java爬虫之Jsoup

Java爬虫之Jsoup

1.Jsoup相关概念 Jsoup很多概念和js类似&#xff0c;可参照对比理解 Document &#xff1a;文档对象。每份HTML页面都是一个文档对象&#xff0c;Document 是 jsoup 体系中最顶层的结构。 Element&#xff1a;元素对象。一个 Document 中可以着包含着多个 Element 对象&#…
阅读更多...
分析C++软件问题的常用分析工具及案例集锦详解

分析C++软件问题的常用分析工具及案例集锦详解

目录 1、库依赖关系查看工具Dependency Walker 2、GDI对象查看工具GDIview 3、PE信息查看工具PeViewer/MiTeC EXE Explorer 4、进程信息查看工具Process Explorer 5、进程监控工具Process Monitor 6、API函数调用监测工具API Monitor C软件异常排查从入门到精通系列教程&…
阅读更多...
SpringBoot 调用mybatis报错：Invalid bound statement (not found):

SpringBoot 调用mybatis报错：Invalid bound statement (not found):

启动SpringBoot报错&#xff1a;Invalid bound statement (not found): 参考此文排查 命中了第6条 记录一手坑爹的Invalid bound statement (not found)&#xff08;六个方面&#xff09; mapper文件路径配置错误 订正以后 问题解决
阅读更多...
从Spring Cloud Alibaba开始聊架构

从Spring Cloud Alibaba开始聊架构

作为SpringCloudAlibaba微服务架构实战派上下册和RocketMQ消息中间件实战派上下册的作者胡弦。 另外我的新书RocketMQ消息中间件实战派上下册&#xff0c;在京东已经上架啦&#xff0c;目前都是5折&#xff0c;非常的实惠。 https://item.jd.com/14337086.htmlhttps://item.jd…
阅读更多...
IP2312U_VSET 5V 2A 单节锂电池同步开关降压充电IC

IP2312U_VSET 5V 2A 单节锂电池同步开关降压充电IC

IP2312U是一款5V输入&#xff0c;支持单节锂电池同步开关降压充电管理的IC。 IP2312U集成功率MOS&#xff0c;采用同步开关架构&#xff0c; 使其在应用时仅需极少的外围器件&#xff0c;并有效减小整体方案的尺寸&#xff0c;降低BOM 成本。 IP2312U的升压开关充电转换器工作频…
阅读更多...
用友U8+CRM 逻辑漏洞登录后台漏洞复现

用友U8+CRM 逻辑漏洞登录后台漏洞复现

0x01 产品简介 用友U8 CRM客户关系管理系统是一款专业的企业级CRM软件&#xff0c;旨在帮助企业高效管理客户关系、提升销售业绩和提供优质的客户服务。 0x02 漏洞概述 用友 U8 CRM客户关系管理系统 reservationcomplete.php文件存在逻辑漏洞&#xff0c;未授权的攻击者通过…
阅读更多...
JVM知识总结（简单且高效）

JVM知识总结（简单且高效）

1. JVM内存与本地内存 JVM内存&#xff1a;受虚拟机内存大小的参数控制&#xff0c;当大小超过参数设置的大小时会报OOM。本地内存&#xff1a;本地内存不受虚拟机内存参数的限制&#xff0c;只受物理内存容量的限制&#xff1b;虽然不受参数的限制&#xff0c;如果所占内存超过…
阅读更多...
从零开始的OpenGL光栅化渲染器构建1

从零开始的OpenGL光栅化渲染器构建1

前言 参照Learnopengl&#xff0c;我开始回顾OpenGL中的内容&#xff0c;最终目标是构建一个玩具级的光栅化渲染器&#xff0c;最好还能和之前做的光线追踪渲染器相结合&#xff0c;希望能够有所收获吧~ 包管理 之前我用CMake配置过OpenGL的环境&#xff0c;这样做出来的项目…
阅读更多...
【Python机器学习】线性模型——岭回归

【Python机器学习】线性模型——岭回归

岭回归也是一种用于回归的线性模型&#xff0c;它的预测公式与线性回归相同&#xff0c;但是在岭回归里&#xff0c;对于系数的选择不仅要在训练数据上得到好的预测结果&#xff0c;而且还要拟合附加约束&#xff0c;还希望系数尽量小&#xff0c;这意味着每个特征对输出的影响…
阅读更多...
实现文本 内容展开 / 收起

实现文本 内容展开 / 收起

<template><el-table :data"tableData" style"width: 100%" height"250"><el-table-columnfixedprop"date"label"日期"width"150"></el-table-column><el-table-columnprop"name…
阅读更多...
trino-435：dynamic catalog数据库存储代码实现

trino-435：dynamic catalog数据库存储代码实现

一、dynamic catalog数据库存储源码分析 dynamic catalog的实现主要涉及到两个类&#xff1a;CoordinatorDynamicCatalogManager、WorkerDynamicCatalogManager&#xff0c;这两个类的详细信息如下&#xff1a; 这两个类主要提供了对catalog的增删改查的方法。trino-435源码中…
阅读更多...
R304S 指纹识别模块指令系统

R304S 指纹识别模块指令系统

1 指令集 1. GR_GetImage 指令代码&#xff1a;01H 功能&#xff1a;从传感器上读入图像存于图像缓冲区 2. GR_GenChar 指令代码&#xff1a;02H 功能&#xff1a;根据原始图像生成指纹特征存于 CharBuffer1 或 CharBuffer2 3. GR_Match 指令代码&#xff1a;03H 功能&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023