Java中的Stream流

一、介绍

1. Stream流的作用

结合了Lambda表达式,简化集合、数组的操作。

2. Stream流的使用步骤

①先得到一条Stream流,并把数据放上去;

获取方式方法名说明
单列集合default Stream<E> stream()Collection中的默认方法
双列集合无法直接使用stream流
数组public static <T> Stream<T> stream(T[] array)Arrays工具类中的静态方法
一堆零散数据public static <T> Stream<T> of(T…values)Stream接口中的静态方法
(1)单列集合:
import java.util.ArrayList;
import java.util.Collections;
import java.util.function.Consumer;
import java.util.stream.Stream;public class StreamDemo2 {public static void main(String[] args) {// 1. 单列集合获取Stream流ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "a", "b", "c", "d", "e");/*// 获取一条流水线,并把集合中的数据放到流水线上Stream<String> stream1 = list.stream();// 使用终结方法打印一条流水线上的所有数据stream1.forEach(new Consumer<String>() {@Overridepublic void accept(String s) {// s:依次表示流水线上的每一个数据System.out.println(s);}});*/// 链式编程list.stream().forEach(s -> System.out.println(s));}
}

(2)双列集合
import java.util.HashMap;public class StreamDemo3 {public static void main(String[] args) {// 双列集合// 1. 创建双列集合HashMap<String, Integer> hm = new HashMap<>();// 2. 添加数据hm.put("aaa", 111);hm.put("bbb", 222);hm.put("ccc", 333);hm.put("ddd", 444);hm.put("eee", 555);// 3. 第一种方式 获取stream流hm.keySet().stream().forEach(s -> System.out.println(s));// 4. 第二种方式 获取stream流hm.entrySet().stream().forEach(s -> System.out.println(s));}
}

(3)数组
import java.util.Arrays;
import java.util.stream.Stream;public class StreamDemo4 {public static void main(String[] args) {// 数组获取stream流// 1. 创建数组int[] arr1 = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10};String[] arr2 = {"a", "b", "c"};// 2. 获取stream流Arrays.stream(arr1).forEach(s -> System.out.println(s));System.out.println("----------------------------------");Arrays.stream(arr2).forEach(s -> System.out.println(s));// 注意:// Stream接口中静态方法of的细节// 方法的形参是一个可变参数,可以传递一堆零散的数据,也可以传递数组// 但是数组必须是引用数据类型的,如果传递基本数据类型,是会把整个数组当作一个元素,放到stream当中。。Stream.of(arr1).forEach(s -> System.out.println(s));  // [I@214c265eStream.of(arr2).forEach(s -> System.out.print(s + " "));  // a b c }
}

(4)一堆零散数据
import java.util.stream.Stream;public class StreamDemo5 {public static void main(String[] args) {// 一堆零散数据获取stream流Stream.of(1, 2, 3, 4, 5).forEach(s -> System.out.println(s));Stream.of("a", "b", "c", "d", "e").forEach(s -> System.out.println(s));}
}

②利用中间方法对流水线上的数据进行各种操作;

注意1:中间方法,返回新的Stream流,原来的Stream流只能使用一次,建议使用链式编程

注意2:修改Stream流中的数据,不会影响原来集合或者数组中的数据

名称说明
Stream<T> filter(Predicate<? super<T> predicate)过滤
Stream<T> limit(long maxSize)获取前几个元素
Stream<T> skip(long n)跳过前几个元素
Stream<T> distinct()元素去重,依赖(hashCode和equals方法)
static<T> Stream<T> concat(Stream a, Stream b)合并a和b两个流为一个流
Stream<R> map(Function<T, R> mapper)转换流中的数据类型
import java.util.ArrayList;
import java.util.Collections;
import java.util.stream.Stream;public class StreamDemo6 {public static void main(String[] args) {ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌", "张无忌", "张无忌", "周芷若", "赵敏", "张强", "张三丰");// 1. fliter 过滤 把以”张“开头的留下,其余数据过滤不要/*list.stream().filter(new Predicate<String>() {@Overridepublic boolean test(String s) {// 如果返回值为true,表示当前数据留下// 如果返回真为false,表示当前数据舍弃不要return s.startsWith("张");}}).forEach(s -> System.out.println(s));*/list.stream().filter(s -> s.startsWith("张")).forEach(s -> System.out.println(s));System.out.println("------------------------------");System.out.println(list);  // 注意:修改Stream流中的数据,不会影响原理集合或者数组中的数据System.out.println("------------------------------");/*Stream<String> stream1 = list.stream().filter(s -> s.startsWith("张"));Stream<String> stream2 = stream1.filter(s -> s.length() == 3);stream2.forEach(s -> System.out.println(s));Stream<String> stream3 = stream1.filter(s -> s.length() == 3);  // java.lang.IllegalStateException*/// 2. limit 获取前几个元素list.stream().limit(3).forEach(s -> System.out.println(s));System.out.println("------------------------------");// 3. skip 跳过前几个元素list.stream().skip(3).forEach(s -> System.out.println(s));System.out.println("------------------------------");// 4. distinct 元素去重list.stream().distinct().forEach(s -> System.out.println(s));System.out.println("------------------------------");// 5. concat 合并a和b两个流为一个流ArrayList<String> list2 = new ArrayList<>();Collections.addAll(list2, "周芷若", "赵六");Stream.concat(list.stream(), list2.stream()).forEach(s -> System.out.println(s));System.out.println("------------------------------");// 6. map 转换流中的数据类型ArrayList<String> list3 = new ArrayList<>();Collections.addAll(list3, "张无忌-15", "周芷若-14", "赵敏-13", "张强-20", "张三丰-100", "张翠山-40", "张良-35");// 只获取里面的年龄并进行打印// 当map方法执行完毕后,流上的数据就变成了整数// 所以再下面的foreach当中,s一次表示流里面的每一个数据,这个数据现在就是整数了/*list3.stream().map(new Function<String, Object>() {@Overridepublic Object apply(String s) {String[] arr = s.split("-");String ageString = arr[1];int age = Integer.parseInt(ageString);return age;}}).forEach(s -> System.out.println(s));System.out.println("------------------------------");*/list3.stream().map(s -> Integer.parseInt(s.split("-")[1])).forEach(s -> System.out.println(s));}
}

③使用终结方法对流水线上的数据进行操作

名称说明
void forEach(Consumer action)遍历
long count()统计
toArray()收集流中的数据,放到数组
collect(Collecctor collector)收集流中的数据,放到集合
import java.util.*;
import java.util.function.Function;
import java.util.function.IntFunction;
import java.util.stream.Collectors;public class StreamDemo7 {public static void main(String[] args) {ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌", "周芷若", "赵敏", "张强", "张三丰");// 1. forEach 遍历// Consumer的泛型:表示流中数据的类型// accept方法的形参s:依次表示流里面的每一个数据// 方法体:对每一个数据的处理操作(打印)/* list.stream().forEach(new Consumer<String>() {@Overridepublic void accept(String s) {System.out.println(s);}});*/list.stream().forEach(s -> System.out.println(s));System.out.println("--------------------------");// 2. count 统计long count = list.stream().count();System.out.println(count);System.out.println("--------------------------");// 3. toArray 收集流中的数据放到数组中Object[] arr1 = list.stream().toArray();System.out.println(Arrays.toString(arr1));System.out.println("--------------------------");// IntFunction的泛型:具体类型的数组// apply的形参:流中的数据的个数,要跟数组的长度保持一致// apply方法的返回值:具体类型的数组// 方法体:就是创建数组// toArray方法的参数的作用:负责创建一个指定类型的数组// toArray方法的底层:会依次得到流里面的每一个数据,并把数据放到数组当中// toArray方法的返回值:是一个装着流里面所有数据的数组/* String[] arr2 = list.stream().toArray(new IntFunction<String[]>() {@Overridepublic String[] apply(int value) {return new String[value];}});System.out.println(Arrays.toString(arr2));System.out.println("--------------------------");*/String[] arr3 = list.stream().toArray(value -> new String[value]);System.out.println(Arrays.toString(arr3));System.out.println("--------------------------");// 4. 收集到List集合当中// 需求:把所有的男性收集起来ArrayList<String> list2 = new ArrayList<>();Collections.addAll(list2, "张无忌-男-15", "周芷若-女-14", "赵敏-女-13", "张强-男-20", "张三丰-男-100", "张翠山-男-40", "张良-男-35");List<String> newList = list2.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toList());System.out.println(newList);System.out.println("--------------------------");// 4. 收集到Set集合当中// 需求:把所有的男性收集起来Set<String> newSet = list2.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toSet());  // 会自动去重System.out.println(newSet);System.out.println("--------------------------");// 4. 收集到Map集合当中// 谁作为键,谁作为值。把所有的男性收集起来// 键:姓名 值:年龄// 注意点:如果我们要收集数据到Map当中,键是不能重复的/* Map<String, Integer> newMap = list2.stream().filter(s -> "男".equals(s.split("-")[1]))*//*toMap:参数一:键的生成规则。参数二:值的生成规则参数一:Function泛型一:表示流中每一个数据的类型泛型二:表示Map集合中键的数据类型方法apply形参:依次表示流里面的每一个数据方法体:生成键的代码返回值:已经生成的键参数二:Function泛型一:表示流中每一个数据的类型泛型二:表示Map集合中值的数据类型方法apply形参:依次表示流里面的每一个数据方法体:生成值的代码返回值:已经生成的值*//*.collect(Collectors.toMap(new Function<String, String>() {@Overridepublic String apply(String s) {return s.split("-")[0];  // 姓名}},new Function<String, Integer>() {@Overridepublic Integer apply(String s) {return Integer.parseInt(s.split("-")[2]);}}));System.out.println(newMap);System.out.println("--------------------------");*/// lambda表达式Map<String, Integer> map2 = list2.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toMap(s -> s.split("-")[0],s -> Integer.parseInt(s.split("-")[2])));System.out.println(map2);}
}

二、案例分析

1. 要求:按照下面的要求完成集合的创建和遍历。

①把所有以“张”开头的元素存储到新集合中;

②把“张”开头的,长度为3的元素再存储到新集合中;

③遍历打印最终结果。

import java.util.ArrayList;public class StreamDemo1 {public static void main(String[] args) {ArrayList<String> list = new ArrayList<>();list.add("张无忌");list.add("周芷若");list.add("赵敏");list.add("张强");list.add("张三丰");list.stream().filter(name -> name.startsWith("张")).filter(name -> name.length() == 3).forEach(name -> System.out.println(name));// 张无忌// 张三丰}
}

2.  数据过滤

        定义一个集合,并添加一些数据1,2,3,4,5,6,7,8,9,10。过滤奇数,只留下偶数,并将结果保存起来。

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;public class StreamDemo8 {public static void main(String[] args) {/*定义一个集合,并添加一些数据1,2,3,4,5,6,7,8,9,10。过滤奇数,只留下偶数,并将结果保存起来。*/// 1. 定义一个集合ArrayList<Integer> list = new ArrayList<>();// 2. 添加一些数据Collections.addAll(list, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10);// 3. 过滤奇数,只留下偶数// 进行判断,如果是偶数,返回true保留List<Integer> newList = list.stream().filter(n -> n % 2 == 0).collect(Collectors.toList());// 4. 打印集合System.out.println(newList);}
}

3. 数据操作

        创建一个ArrayList集合,并添加以下字符串,字符串中前面是姓名,后面是年龄。”zhangsan, 23", "lisi, 24", "wangwu, 25"。保留年龄大于等于24岁的人,并将结果收到到Map集合中,姓名为键,年龄为值。

import java.util.ArrayList;
import java.util.Map;
import java.util.stream.Collectors;public class StreamDemo9 {public static void main(String[] args) {/*创建一个ArrayList集合,并添加以下字符串,字符串中前面是姓名,后面是年龄。”zhangsan, 23", "lisi, 24", "wangwu, 25"。保留年龄大于等于24岁的人,并将结果收到到Map集合中,姓名为键,年龄为值。*/// 1. 创建一个ArrayList集合ArrayList<String> list = new ArrayList<>();// 2. 添加以下字符串list.add("zhangsan, 23");list.add("lisi, 24");list.add("wangwu, 25");// 3. 保留年龄大于等于24岁的人Map<String, Integer> map = list.stream().filter(s -> Integer.parseInt(s.split(", ")[1]) >= 24).collect(Collectors.toMap(s -> s.split(", ")[0],s -> Integer.parseInt(s.split(", ")[1])));System.out.println(map);}
}

4. 数据操作

        现有两个ArrayList集合,第一个集合:存储6名男演员的名字和年龄。第二个集合:存储6名女演员的名字和年龄。姓名和年龄中间用逗号隔开。比如,张三,23。

        要求完成下面的操作:①男演员只要名字为3个字的前两个人;②女演员只要姓杨的,并且不要第一个;③把过滤后的男演员姓名和女演员姓名合并到一起;④将上一步的演员信息封装成Actor对象;⑤将所有的演员对象都保存到List集合中。

备注:演员类Actor,属性只有一个:name,age

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.Stream;public class StreamDemo10 {public static void main(String[] args) {/*现有两个ArrayList集合,第一个集合:存储6名男演员的名字和年龄。第二个集合:存储6名女演员的名字和年龄。姓名和年龄中间用逗号隔开。比如,张三,23。要求完成下面的操作:①男演员只要名字为3个字的前两个人;②女演员只要姓杨的,并且不要第一个;③把过滤后的男演员姓名和女演员姓名合并到一起;④将上一步的演员信息封装成Actor对象;⑤将所有的演员对象都保存到List集合中。备注:演员类Actor,属性只有一个:name,age*/// 1. 创建两个ArrayList集合ArrayList<String> manList = new ArrayList<>();ArrayList<String> womenList = new ArrayList<>();// 2. 添加数据Collections.addAll(manList, "小小蔡, 24", "小小叶, 23", "小小刘, 22", "小吴, 25", "小小谷, 23", "小李, 26");Collections.addAll(womenList, "杨小甜, 23", "杨小小, 21", "杨小鞠, 22", "小单, 24", "刘小陈, 22", "小小曲, 23");// 3. 男演员只要名字为3个字的前两个人Stream<String> stream1 = manList.stream().filter(s -> s.split(", ")[0].length() == 3).limit(2);// 4. 女演员只要姓杨的,并且不要第一个Stream<String> stream2 = womenList.stream().filter(s -> s.split(", ")[0].startsWith("杨")).skip(1);// 5. 把过滤后的男演员姓名和女演员姓名合并到一起// 6. 将上一步的演员信息封装成Actor对象(类型转换)/*Stream.concat(stream1, stream2).map(new Function<String, Actor>() {@Overridepublic Actor apply(String s) {String name = s.split(", ")[0];int age = Integer.parseInt(s.split(", ")[1]);return new Actor(name, age);}}).forEach(s -> System.out.println(s));*/List<Actor> list = Stream.concat(stream1, stream2).map(s -> new Actor(s.split(", ")[0], Integer.parseInt(s.split(", ")[1]))).collect(Collectors.toList());System.out.println(list);}
}

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

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

相关文章

【ubuntu的python报错】/usr/bin/env: “python3\r”: 没有那个文件或目录

【ubuntu的python报错】/usr/bin/env: “python3\r”: 没有那个文件或目录 通过apt-get命令安装dos2unix的包&#xff0c;然后通过dos2unix这个命令即可完成转换。 通过apt-get命令安装dos2unix的包&#xff0c;然后通过dos2unix这个命令即可完成转换。 sudo apt-get install …

git -- 提交规范

参考链接 – 1 参考链接 – 2 参考链接 – 3 以下常见的Git代码提交规范,可以根据团队的具体情况进行调整和补充。重要的是,团队成员要保持一致性,遵守代码提交规范,以便更好地协作和维护代码库。 为什么使用同一提交代码规范有如下原因: 自动化生成 CHANGELOG。基于提交的…

是德科技keysight N1912A双通道功率计

181/2461/8938产品概述&#xff1a; Keysight(原Agilent) N1912A P系列双通道功率计可提供峰值、峰均比、平均功率、上升时间、下降时间、最大功率值、最小功率值以及宽带信号的统计数据。 Keysight(原Agilent) N1912A P系列双通道功率计, 可提供峰值、峰均比、平均功率、上升…

Redis安装详细教程

Redis安装详细教程 文章目录 Redis安装详细教程前言一、windows下安装Redis1、下载地址2、启动redis服务3、连接redis 二、Linux下安装Redis&#xff1a;直接安装1、下载并安装 三、Linux下安装Redis&#xff1a;Docker中安装 前言 一、windows下安装Redis 1、下载地址 官方下…

Docker 容器中运行 JAR 文件的方法

由于 Docker 容器通常需要一个操作系统级环境来运行应用程序&#xff0c;而 JAR 文件&#xff08;Java ARchive&#xff09;是一个包含 Java 应用程序或库的文件&#xff0c;需要 Java 运行时环境&#xff08;JRE&#xff09;来执行。 以下是运行 JAR 文件的基本步骤&#xff…

冒泡排序,选择排序,插入排序,希尔排序,堆排序,快速排序的递归版。(直接可用,懒人必备)。

注意&#xff1a;1.在使用前需要先将Swap函数放在最前面。基本上都用了了Swap函数。 2.完成的是升序版本&#xff0c;如想逆序&#xff0c;自行更改。 目录 Swap函数&#xff1a; 冒泡排序&#xff1a; 选择排序 插入排序 希尔排序 堆排序 快速排序 Swap函数&#xff1a…

Vue 3项目中结合Element Plus的<el-menu>和CSS3创建锚点,以实现点击菜单项时平滑滚动到对应的锚点目标

安装Element Plus&#xff1a; 确保已经安装了Element Plus库。可以使用npm或者yarn进行安装&#xff0c;具体步骤与上文提到的相同。 引入Element Plus&#xff1a; 在你的Vue 3项目中引入所需的Element Plus组件和样式。 创建el-menu&#xff1a; 在Vue组件中使用<el-me…

Unity发布webgl之后打开PDF文件,不使用js,不和浏览器交互

创建一个按钮&#xff0c;然后点击就会打开 在webgl下要使用这样的路径拼接&#xff0c;不然就会报错。 btnBook.onClick.AddListener(() >{var uri new System.Uri(Path.Combine(Application.streamingAssetsPath "/Books", "文档.pdf"));Debug.Log…

PyTorch深度学习:如何实现遥感影像的自动化地物分类?

我国高分辨率对地观测系统重大专项已全面启动&#xff0c;高空间、高光谱、高时间分辨率和宽地面覆盖于一体的全球天空地一体化立体对地观测网逐步形成&#xff0c;将成为保障国家安全的基础性和战略性资源。未来10年全球每天获取的观测数据将超过10PB&#xff0c;遥感大数据时…

前端根据pdf连接点击下载pdf而不是直接打开

参考地址: https://www.cnblogs.com/jackson-yqj/p/11321275.html /*** 文件链接转文件流下载--主要针对pdf 解决谷歌浏览器a标签下载pdf直接打开的问题* param url &#xff1a;文件链接* param fileName &#xff1a;文件名;* param type &#xff1a;文件类型;*/functio…

Azure databricks spark overwrite 全量更新的时候容易碰到的问题

原因&#xff1a;Azure databricks spark overwrite 全量ADS层表更新的时候容易碰到的问题正在写入结果有服务请求这个表的数据那如何避免呢&#xff1f; 1、 databricks spark overwrite 到的的时候会先TRUNCATE TABLE 然后再写入&#xff0c;就会碰到查询是空的情况&#xff…

Prompt进阶系列4:LangGPT(构建高性能Prompt实践指南)--结构化Prompt

Prompt进阶系列4:LangGPT(构建高性能Prompt实践指南)–结构化Prompt 1.结构化 Prompt简介 结构化的思想很普遍&#xff0c;结构化内容也很普遍&#xff0c;我们日常写作的文章&#xff0c;看到的书籍都在使用标题、子标题、段落、句子等语法结构。结构化 Prompt 的思想通俗点…

从零开始学Spring Boot系列-集成Kafka

Kafka简介 Apache Kafka是一个开源的分布式流处理平台&#xff0c;由LinkedIn公司开发和维护&#xff0c;后来捐赠给了Apache软件基金会。Kafka主要用于构建实时数据管道和流应用。它类似于一个分布式、高吞吐量的发布-订阅消息系统&#xff0c;可以处理消费者网站的所有动作流…

[音视频学习笔记]七、自制音视频播放器Part2 - VS + Qt +FFmpeg 写一个简单的视频播放器

前言 话不多说&#xff0c;重走霄骅登神路 前一篇文章 [音视频学习笔记]六、自制音视频播放器Part1 -新版本ffmpeg&#xff0c;Qt VS2022&#xff0c;都什么年代了还在写传统播放器&#xff1f; 本文相关代码仓库&#xff1a; MediaPlay-FFmpeg - Public 转载雷神的两个流程…

常用的IDE推荐

程序员在选择集成开发环境&#xff08;IDE&#xff09;时&#xff0c;会考虑多种因素&#xff0c;包括易用性、功能丰富性、性能以及是否支持他们正在使用的编程语言。以下是一些建议的IDE及其优点&#xff1a; 1.JetBrains PyCharm&#xff1a;专为Python开发而设计的IDE。 优…

Flutter动画(一)Ticker、Animate 原理

在任何系统的UI框架中&#xff0c;动画原理都是类似的&#xff0c;即&#xff1a;在一段时间内&#xff0c;快速地多次改变UI外观&#xff1b;由于人眼会产生视觉暂留&#xff0c;所以最终看到的就是一个“连续”的动画。 Flutter中对动画进行了抽象&#xff0c;主要涉及 Anim…

ubuntu生成 设置 core文件

ubuntu生成&设置core文件&#xff0c;调试段错误_ubuntu生成core文件-CSDN博客 ubuntu设置core文件_ubuntu core文件默认位置-CSDN博客 ulimit -a sudo vim /etc/profile #或者 vi ~/.bashrc ulimit -c unlimited #添加&#xff0c; 退出source /etc/profile sudo…

100个python代码(三)

列表排序: pythonCopy code my_list [3, 1, 4, 1, 5, 9, 2] my_list.sort() 生成器表达式: pythonCopy code gen_exp (x**2 for x in range(10)) for x in gen_exp: print(x) 字典推导式: pythonCopy code square_dict {x: x**2 for x in range(5)} 集合推导式: p…

后端前行Vue之路(一):初识Vue

1.Vue是什么 Vue (读音 /vjuː/&#xff0c;类似于 view) 是一套用于构建用户界面的渐进式框架。与其它大型框架不同的是&#xff0c;Vue 被设计为可以自底向上逐层应用。Vue 的核心库只关注视图层&#xff0c;不仅易于上手&#xff0c;还便于与第三方库或既有项目整合。另一方…

Redis系列学习文章分享---第十四篇(Redis多级缓存--封装Http请求+向tomcat发送http请求+根据商品id对tomcat集群负载均衡)

目录 Redis的实战篇-多级缓存1-多级缓存-怎么封装Http请求工具&#xff1f;示例代码 2-多级缓存-怎么向tomcat发送http请求&#xff1f;示例代码 3-多级缓存-怎么根据商品id对tomcat集群负载均衡&#xff1f;4-多级缓存-Redis缓存预热怎么做&#xff1f;示例代码 5-多级缓存-怎…