告别循环!用Stream优雅处理集合

news2025/4/18 13:54:13

什么是stream?

也叫Stream流,是jdk8新增的一套API(java.util.stream.*)可以用于操作集合或者数组的数据。

优势:Stream流大量的结合了Lambda语法的风格编程,提供了一种更加强大,更加简单的方式操作或者数组中的数据,代码更简洁,可读性更好。

体验Stream流

在这里插入图片描述

原来的操作方法

ArrayList<String> list1 = new ArrayList<String>();
list1.add("赵无极");
list1.add("赵敏");
list1.add("张双");
list1.add("张三a");
list1.add("周娅");
//1.把所有以“张”开头的元素存储到新集合中
ArrayList<String> list2 = new ArrayList<>();
for(String name : list1){
    if(name.startsWith("张")){
        list2.add(name);
    }
}
System.out.println(list2);
//把“张”开头的,长度为3的元素再存储到新集合中
ArrayList<String> list3 = new ArrayList<>();
for(String name : list2){
    if(name.length() == 2){
        list3.add(name);
    }
}
System.out.println(list3);

是不是很繁琐,那我们就用Stream流来试一下。

我们先拿到这个集合,去调它的一个方法叫stream,得到Stream流方法,而它也支持链式编程的,可以继续用点(.)来调用它的方法,调用filter方法,这个方法的作用是过滤。

list1.stream().filter(name->name.startsWith("张")).filter(name->name.length()==3).forEach(name->System.out.println(name));
  1. list1.stream()
    

    list1集合转换成一个流。流是Java 8引入的一个抽象概念,它可以对集合进行各种高效的聚合操作。

  2. .filter(name->name.startsWith("张"))
    

    使用filter方法对流中的元素进行筛选。name->name.startsWith("张")是一个Lambda表达式,它定义了一个谓词(Predicate),用于检查每个元素(这里是name)是否以"张"开头。只有满足这个条件的元素才会被保留在流中。

  3. .filter(name->name.length()==3)
    

    再次使用filter方法对已经筛选过的流进行进一步筛选。这次的筛选条件是元素的长度是否等于3。同样,只有满足这个条件的元素才会被保留在流中。

  4. .forEach(name->System.out.println(name))
    

    使用forEach方法对筛选后的流中的每个元素执行操作。name->System.out.println(name)是一个Lambda表达式,它定义了对每个元素执行的操作,即打印出每个元素。

Stream流的使用步骤

图片的形式展示

在这里插入图片描述

常见方法

如何获取Stream流?

获取集合的Stream流

//Collection提供的如下方法
default Stream<E> stream();

获取数组的Stream流

//Arrays类提供的如下方法
public static <T> stream(T[] array);
//Stream类提供的如下方法
public static Stream<T> of(T...values);

例题

1.如何获取List集合的Stream流?

List<String> names = new ArrayList<>();
Collections.addAll(names,"张三丰","张无忌","周志","赵明");
Stream<String> stream = names.stream();
stream.filter(n -> n.length()>2).forEach(n -> System.out.println(n));//张三丰 张无忌

2.如何获取Set集合的Stream流?

Set<String> set = new HashSet<>();
Collections.addAll(set,"张三丰","张无忌","周志","赵明");
Stream<String> stream1 = set.stream();
stream1.filter(n -> n.contains("三")).forEach(n -> System.out.println(n));//张三丰

3.如何获取Map集合的Stream流?

Map集合不能直接使用stream调用Stream流,因为Stream方法是Collection提供的,Map集合不属于Collection。

  1. keySet(): 返回映射中包含的键的Set视图。此方法返回的集合支持通过流操作处理映射中的所有键。
  2. values(): 返回映射中包含的值的Collection视图。此方法返回的集合支持通过流操作处理映射中的所有值。
  3. entrySet(): 返回映射中包含的键值对的Set视图。此方法返回的集合支持通过流操作处理映射中的所有键值对(Map.Entry)。
Map<String, String> map = new HashMap<>();
map.put("张三", "30");
map.put("李四", "25");
map.put("张伟", "35");
map.put("王五", "40");

// 对Map的值进行流操作
map.values().stream()
    .filter(name -> name.startsWith("张"))
    .filter(name -> name.length() == 3)
    .forEach(name -> System.out.println(name));

// 对Map的键进行流操作
map.keySet().stream()
    .filter(name -> name.startsWith("张"))
    .filter(name -> name.length() == 3)
    .forEach(name -> System.out.println(name));

// 对Map的键值对进行流操作
map.entrySet().stream()
    .filter(entry -> entry.getValue().startsWith("张"))
    .filter(entry -> entry.getValue().length() == 3)
    .forEach(entry -> System.out.println(entry.getKey()));

4.如何获取数组的Stream流?

String[] names2= {"张翠山“,”东方不败”,”唐大山”,”独孤求败”}Stream< String> s1= Arrays. stream(names2);
Stream< String> s2= Stream. of(names2);|	I
  • Arrays.stream() 是一个静态方法,它接受一个数组作为参数,并返回一个流,该流包含数组中的所有元素。
  • Stream.of() 是一个静态方法,它接受一系列参数,并返回一个包含这些参数的流。

Stream流常见的中间方法

中间方法指的是调用完成后会返回新的Stream流,可以继续使用(支持链式编程)。

在这里插入图片描述

示例:

需求1:找出成绩大于等于60分的数据,并升序后,再输出。

List<Double> scores = new ArrayList<Double>();
Collections.addAll(scores,88.5,100.0,68.0,99.8,9.5);
scores.stream().filter(score -> score > 88.5).forEach(score -> System.out.println(score));//100.0 99.8

需求2,找出年龄大于等于23,且年龄小于等于30岁的学生,并按照年龄降序输出。

List< Student> students = new ArrayList<>();
Student s1= new Student(name: "蜘蛛精", age:26, height:172.5);
Student s2= new Student(name: "蜘蛛精", age:26, height:172.5);
Student s3 = new Student(name: "紫霞", age: 23, height:167.6);
Student s4= new Student(name: "白晶晶", age:25, height:169.0);
Student s5= new Student(name: "牛魔王", age:35, height:183.3);
Student s6= new Student(name: "牛夫人", age:34, height:168.5);
Collections. addAll(students, s1, s2, s3, s4, s5, s6);
//需求2:找出年龄大于等于23,且年龄小于等于30岁的学生,并按照年龄降序输出。
students. stream(). filter(s - > s. getAge() >=23&& s. getAge() <= 30)
. sorted(). forEach(s - > System. out. println(s));

该程序会报错是因为sorted方法不知道该以什么为依据进行排序,

如果我们想要按照年龄进行排序,就需要重载sort方法,用Lambda表达式指定排序的方法。

students. stream(). filter(s - > s. getAge() >=23&& s. getAge() <=30). sorted((o1, o2) - > o2. getAge() - o1. getAge()). forEach(s - > System. out. println(s));

需求3:取出身高最高的前3名学生,并输出。

Double类型不能直接作差,用Double的一个compare方法

students. stream().sorted((o1, o2) - > Double.compare(o2.getHeight(), o1.getHeight())). limit(3). forEach(s - > System. out. println(s));|

需求4:取出身高倒数的2名学生,并输出。

students. stream().sorted((o1, o2) - > Double.compare(o2.getHeight(), o1.getHeight())). skip(students. size() -2). forEach(System. out:: println);

需求5:找出身高超过168的学生叫什么名字,要求去除重复的名字,再输出

students. stream(). filter(s - > s. getHeight() >168). map(Student::getName). distinct(). forEach(System. out:: println);

distinct去重复,自定义类型的对象(希望内容一样就认为重复,重写hashCode, equals)

合并两个流为一个流

Stream< String> st1= Stream. of("张三“,”李四”);
Stream< String> st2= Stream. of("张三2", "李四2", "王五“);
Stream< String> allSt = Stream. concat(st1, st2);
allSt.forEach(System.out::println);

如果两个流的类型不样,那么最后合并的流类型用object。

Stream流常见的终结方法

终结方法指的是调用完成后,不会返回新Stream了,没法继续使用流了。

在这里插入图片描述

示例

List< Student> students = new ArrayList<>();
Student s1= new Student( "蜘蛛精",26,172.5);
Student s2= new Student( "蜘蛛精",26,172.5);
Student s3 = new Student( "紫霞", 23, 167.6);
Student s4= new Student( "白品品", 25,169.0);
Student s5= new Student( "牛魔王",35, 183.3);
Student s6= new Student("牛夫人",34, 168.5);
Collections. addAll(students, s1, s2, s3, s4, s5, s6);

需求1:请计算出身高超过168的学生有几人。

long size = students.stream().filter(higher -> higher.getHeight() > 168).count();
System.out.println(size);//5

需求2:请找出身高最高的学生对象,并输出。

Student s = students.stream().max((o1, o2) -> Double.compare(o1.getHeight(), o2.getHeight())).get();
System.out.println(s);
//Student{name='牛魔王', age=35, height=183.3}

需求3:请找出身高最矮的学生对象,并输出。

Student ss = students.stream().min((o1, o2) -> Double.compare(o1.getHeight(), o2.getHeight())).get();
System.out.println(ss);
//Student{name='紫霞', age=23, height=167.6}

需求4:请找出身高超过170的学生对象,并放到一个新集合中去返回。

流只能收集一次

List< Student> students1= students. stream(). filter(a - > a. getHeight() >170). collect(Collectors. toList());
System. out. println(students1);
Set< Student> students2= students. stream(). filter(a - > a. getHeight() >170). collect(Collectors. toSet());
System. out. println(students2);

需求5:请找出身高超过170的学生对象,并把学生对象的名字和身高,存入到一个Map集合返回。

Map< String, Double> map =students. stream(). filter(a - > a. getHeight() >170). distinct(). collect(Collectors. toMap(a - > a. getName(), a - > a. getHeight()));
System. out. println(map);

总结:

“Stream 不仅是一种 API,更是思维方式的升级——从‘如何做’到‘做什么’。掌握它,你的代码会变得更简洁、更富有表达力。现在就去试试吧!”

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

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

相关文章

Linux电源管理、功耗管理 和 发热管理 (CPUFreq、CPUIdle、RPM、thermal、睡眠 和 唤醒)

1 架构图 1.1 Linux内核电源管理的整体架构 《Linux设备驱动开发详解&#xff1a;基于最新的Linux4.0内核》图19.1 1.2 通用的低功耗软件栈 《SoC底层软件低功耗系统设计与实现》 1.3 低功耗系统的架构设计&#xff1b;图1-3 2 系统级睡眠和唤醒管理 Linux系统的待机、睡眠…

OSCP - Proving Grounds -FunboxEasy

主要知识点 弱密码路径枚举文件上传 具体步骤 首先是nmap扫描一下&#xff0c;虽然只有22&#xff0c;80和3306端口&#xff0c;但是事情没那么简单 Nmap scan report for 192.168.125.111 Host is up (0.45s latency). Not shown: 65532 closed tcp ports (reset) PORT …

Vue 3 国际化实战:支持 Element Plus 组件和语言持久化

目录 Vue 3 国际化实战&#xff1a;支持 Element Plus 组件和语言持久化实现效果&#xff1a;效果一、中英文切换效果二、本地持久化存储效果三、element Plus国际化 vue3项目国际化实现步骤第一步、安装i18n第二步、配置i18n的en和zh第三步&#xff1a;使用 vue-i18n 库来实现…

1.阿里云快速部署Dify智能应用

一、宝塔面板 宝塔面板是一款功能强大且易于使用的服务器管理软件&#xff0c;支持Linux和Windows系统&#xff0c;通过web端可视化操作&#xff0c;优化了建站流程&#xff0c;提供安全管理、计划任务、文件管理以及软件管理等功能。 1.1 宝塔面板的特点与优势 易用性 宝塔面…

在pycharm配置虚拟环境和jupyter,解决jupyter运行失败问题

记录自己pycharm环境配置和解决问题的流程。 解决pycharm无法运行jupyter代码&#xff0c;仅运行import板块显示运行失败&#xff0c;但是控制台不输出任何错误信息&#xff0c;令人困惑。 遇到的问题是&#xff1a;运行代码左下角显示运行失败但是有没有任何的输出错误信息。 …

【Docker】离线安装Docker

背景 离线安装Docker的必要性&#xff0c;第一&#xff0c;在目前数据安全升级的情况下&#xff0c;很多外网已经基本不好访问了。第二&#xff0c;如果公司有对外部署的需求&#xff0c;那么难免会存在对方只有内网的情况&#xff0c;那么我们就要做到学会离线安装。 下载安…

极简cnn-based手写数字识别程序

1.先看看识别效果&#xff1a; 这个程序识别的是0~9的一组手写数字&#xff0c;这是最终的识别效果&#xff0c;为1&#xff0c;代表识别成功&#xff0c;0为失败。 然后数据源是&#xff1a;ds deeplake.load(hub://activeloop/optical-handwritten-digits-train)里面是一组…

C++核心机制-this 指针传递与内存布局分析

示例代码 #include<iostream> using namespace std;class A { public:int a;A() {printf("A:A()的this指针&#xff1a;%p!\n", this);}void funcA() {printf("A:funcA()的this指针&#xff1a;%p!\n", this);} };class B { public:int b;B() {prin…

vue3 history路由模式刷新页面报错问题解决

在使用history路由模式时刷新网页提示404错误&#xff0c;这是改怎么办呢。 官方解决办法 https://router.vuejs.org/zh/guide/essentials/history-mode.html

PHP爬虫教程:使用cURL和Simple HTML DOM Parser

一个关于如何使用PHP的cURL和HTML解析器来创建爬虫的教程&#xff0c;特别是处理代理信息的部分。首先&#xff0c;我需要确定用户的需求是什么。可能他们想从某个网站抓取数据&#xff0c;但遇到了反爬措施&#xff0c;需要使用代理来避免被封IP。不过用户没有提到具体的目标网…

3.2.2.1 Spring Boot配置静态资源映射

在Spring Boot中配置静态资源映射&#xff0c;可以通过默认路径或自定义配置实现。默认情况下&#xff0c;Spring Boot会在classpath:/static/等目录下查找静态资源。若需自定义映射&#xff0c;可通过实现WebMvcConfigurer接口的addResourceHandlers方法或在全局配置文件中设置…

# 更换手机热点后secureCRT无法连接centOS7系统

更换手机热点后secureCRT无法连接centOS7系统 一、问题描述 某些情况下&#xff0c;我们可能使用手机共享热点而给电脑联网。本来用一个手机热点共享网络时&#xff0c;SecureCRT可以正常连接到CentOS 7虚拟机&#xff0c;当更换一个手机热点时&#xff0c;突然发现SecureCR…

jupyter notebook 无法启动- markupsafe导致

一、运行jupyter notebook和Spyder报错&#xff1a;(已安装了Anaconda&#xff0c;以前可打开) 1.背景&#xff1a;为了部署机器学习模型&#xff0c;按教程直接安装了flask 和markupsafe&#xff0c;导致jupyter notebook&#xff0c;Spyder 打不开。 pip install flas…

CTF web入门之命令执行 完整版

web29 文件名过滤 由于flag被过滤,需要进行文件名绕过,有以下几种方法: 1.通配符绕过 fla?.* 2.反斜杠绕过 fl\ag.php 3.双引号绕过 fl’‘ag’.php 还有特殊变量$1、内联执行等 此外 读取文件利用cat函数,输出利用system、passthru 、echo echo `nl flag.php`; ec…

Java 开发工具:从 Eclipse 到 IntelliJ IDEA 的进化之路

Java 开发工具&#xff1a;从 Eclipse 到 IntelliJ IDEA 的进化之路 在 Java 开发的历史长河中&#xff0c;开发工具的演变不仅改变了程序员的编码方式&#xff0c;也深刻影响了整个行业的开发效率和代码质量。从 Eclipse 到 IntelliJ IDEA&#xff0c;这不仅是工具的更替&…

GPT - 2 文本生成任务全流程

数据集下载 数据预处理 import json import pandas as pdall_data []with open("part-00018.jsonl",encoding"utf-8") as f:for line in f.readlines():data json.loads(line)all_data.append(data["text"])batch_size 10000for i in ran…

红宝书第四十三讲:基于资料的数据可视化工具简单介绍:D3.js 与 Canvas绘图

红宝书第四十三讲&#xff1a;基于资料的数据可视化工具简单介绍&#xff1a;D3.js 与 Canvas绘图12 资料取自《JavaScript高级程序设计&#xff08;第5版&#xff09;》。 查看总目录&#xff1a;红宝书学习大纲 一、D3.js&#xff1a;数据驱动文档的王者 1 核心特性&#x…

深入理解 Vue 的数据代理机制

何为数据代理&#xff1f; 通过一个对象代理对另一个对象中的属性的操作&#xff08;读/写&#xff09;&#xff0c;就是数据代理。 要搞懂Vue数据代理这个概念&#xff0c;那我们就要从Object.defineProperty()入手 Object.defineProperty()是Vue中比较底层的一个方法&…

Java excel导入/导出导致内存溢出问题,以及解决方案

excel导入/导出导致内存溢出问题&#xff0c;以及解决方案 1、内存溢出问题导入功能重新修正&#xff0c;采用SAX的流式解析数据。并结合业务流程。导出功能&#xff1a;由于精细化了业务流程&#xff0c;导致比较代码比较冗杂&#xff0c;就只放出最简单的案例。 1、内存溢出问…

10 个最新 CSS 功能已在所有主流浏览器中得到支持

前言 CSS 不断发展&#xff0c;新功能使我们的工作更快、更简洁、更强大。得益于最新的浏览器改进&#xff08;Baseline 2024&#xff09;&#xff0c;许多新功能现在可在所有主要引擎上使用。以下是您可以立即开始使用的10 CSS新功能。 1. Scrollbar-Gutter 和 Scrollbar-Co…