【JAVA入门】Day34 - Stream流

【JAVA入门】Day34 - Stream流

文章目录

  • 【JAVA入门】Day34 - Stream流
    • 一、Stream 流的作用和使用步骤
    • 1.Stream流的创建，数据的添加
    • 2. Stream流的中间方法
    • 3. Stream流的终结方法

        Stream 流有什么作用？我们看一个例子：

【练习】需求：按照下面的要求完成集合的创建和遍历。
①把所有以“张”开头的元素存储到新集合中。
②把“张”开头的，长度为3的元素再存储到新集合中。
③遍历打印最终结果。
        以往我们是这样写的。

package Stream;import java.util.ArrayList;public class StreamDemo {public static void main(String[] args) {/*①把所有以“张”开头的元素存储到新集合中。
②把“张”开头的，长度为3的元素再存储到新集合中。
③遍历打印最终结果。*/ArrayList<String> list1 = new ArrayList<>();list1.add("张无忌");list1.add("周芷若");list1.add("赵敏");list1.add("张强");list1.add("张三丰");//①把所有以“张”开头的元素存储到新集合中。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() == 3){list3.add(name);}}System.out.println(list3);//③遍历打印最终结果。for (String s : list3) {System.out.println(s);}}
}

        使用 Stream 流我们可以这样写。

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

        一行代码就完成了所有任务。可以说是大大简化了代码。

一、Stream 流的作用和使用步骤

        Stream 本身是结合了 Lambda 表达式，简化了集合、数组的各种操作。
        Stream的使用理论步骤是：
①先得到一条 Stream 流（流水线），并把数据放上去。
②利用 Stream 流中的 API 进行各种操作，包括：过滤、转换、统计、打印等等。
        Stream 流中的方法分为两种：中间方法（过滤、转换）、终结方法（统计、打印）。中间方法就是调用完毕之后还可以调用其他方法；终结方法就是流的最后一步，调用完毕之后，不能再调用其他方法。
        下面我们根据步骤分别介绍相关方法。
在这里插入图片描述

1.Stream流的创建，数据的添加

1.单列集合创建流水线：

package Stream;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) {System.out.println(s);}});*///利用Lambda表达式简化list.stream().forEach(s -> System.out.println(s));}
}

2.双列集合间接使用流水线：

package Stream;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);//3.获取stream流，放入键hm.keySet().stream().forEach(s -> System.out.println(s));//4.第二种获取stream流的办法，放入键值对hm.entrySet().stream().forEach(s -> System.out.println(s));}
}

3.数组使用流水线：

package Stream;import java.util.Arrays;public class StreamDemo4 {public static void main(String[] args) {//1.创建数组int[] arr = {1,2,3,4,5,6,7,8,9,10};String[] arr2 = {"a","b","c","d","e"};//2.创建stream流Arrays.stream(arr).forEach(s -> System.out.println(s));Arrays.stream(arr2).forEach(s -> System.out.println(s));}
}

4.大量零散数据使用流水线：

package Stream;import java.util.stream.Stream;public class StreamDemo5 {public static void main(String[] args) {//public static<T> Stream<T> of(T...values)     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));}
}

要注意：

//数组可以作为Stream.of()的参数，但必须是引用类型的，如果传递基本数据类型的数组，会把整个数组当成一个元素放入Stream
Stream.of(arr2).forEach(s -> System.out.println(s));

2. Stream流的中间方法

        Stream 流的中间方法如下。
在这里插入图片描述
        其中要注意 distinct() 方法去重，依赖于那两个常用方法，如果要去重的是自定义数据类型，务必重写这两个方法。
        还要注意：中间方法会返回新的 Stream 流，而原来的 Stream 流只能用一次（调一次方法就关闭了），所以建议使用链式编程节省代码量。
        还要注意：修改 Stream 流中的数据是不会影响原来集合或者数组中的数据的。
        部分方法使用例代码如下。

package Stream;import java.util.ArrayList;
import java.util.Collections;
import java.util.function.Predicate;public class StreamDemo6 {public static void main(String[] args) {/*filter  过滤limit   获取前几个元素skip    跳过前几个元素*/ArrayList<String> list = new ArrayList<>();Collections.addAll(list,"张无忌","周芷若","赵敏","张三丰","张翠山","张良","王二麻子","谢广坤");//filter 过滤 把“张”开头的留下，其他不要/*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(list);   //[张无忌, 周芷若, 赵敏, 张三丰, 张翠山, 张良, 王二麻子, 谢广坤]}
}

package Stream;import java.util.ArrayList;
import java.util.Collections;
import java.util.stream.Stream;public class StreamDemo7 {public static void main(String[] args) {/*distinct 元素去重，依赖hashCode和equals方法concat   合并a和b两个流为一个流*/ArrayList<String> list1 = new ArrayList<>();Collections.addAll(list1, "张无忌","张无忌","张无忌","张强","张三丰","张翠山","张良","王二麻子","谢广坤");ArrayList<String> list2 = new ArrayList<>();Collections.addAll(list2,"周芷若","赵敏");//元素去重list1.stream().distinct().forEach(s -> System.out.println(s));//流的合并Stream.concat(list1.stream(),list2.stream()).forEach(s -> System.out.println(s));}
}

package Stream;import java.util.ArrayList;
import java.util.Collections;
import java.util.function.Function;public class StreamDemo8 {public static void main(String[] args) {/*map     转换流中的数据类型*/ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌-15","周芷若-14","赵敏-13","张强-20","张三丰-100","张翠山-40","张良-35","王二麻子-37","谢广坤-41");//获取里面的年龄并进行打印//第一个类型：表示流中原本的数据类型//第二个类型：表示要转换之后的数据类型//apply的形参s:表示流里面的每一个数据//返回值：表示转换之后的数据类型list.stream().map(new Function<String, Integer>() {@Overridepublic Integer apply(String s) {String[] arr = s.split("-");String ageString = arr[1];                  //arr[0]是名字,arr[1]是年龄int age = Integer.parseInt(ageString);return age;}}).forEach(s -> System.out.println(s));//简写为Lambda表达式list.stream().map(s -> Integer.parseInt(s.split("-")[1])).forEach(s -> System.out.println(s));}
}

3. Stream流的终结方法

        Stream 的终结方法使用完毕后，Stream 流就关闭了，所以要写在最后。
在这里插入图片描述
        以下演示了如何遍历、统计一个流中的数据，并将流中的数据收集到一个数组当中，使用的方法是 toArray()，其中的代码都可以用 Lambda 表达式来改写。

package Stream;import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.function.Consumer;
import java.util.function.IntFunction;public class StreamDemo9 {public static void main(String[] args) {ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌","张无忌","张无忌","张强","张三丰","张翠山","张良","王二麻子","谢广坤");//void forEach(Consumer action) 遍历//重写的方法体是对每一个数据的操作
/*list.stream().forEach(new Consumer<String>() {@Overridepublic void accept(String s) {System.out.println(s);}});
*/list.stream().forEach(s -> System.out.println(s));//long count() 统计System.out.println(list.stream().count());//toArray() 收集流中数据，放入数组中Object[] arr1 = list.stream().toArray();                //空参是转化为Object类型，放入Object数组中System.out.println(Arrays.toString(arr1));              //调用Arrays.toString方法转化为字符串打印//IntFunction的泛型是：具体类型的数组 <? extends Object[]>//apply方法的形参：流中数据的个数，要和数组长度保持一致//apply的返回值：返回具体的类型的数组//apply的方法体：创建数组，流中有多少数据，数组长度就填多少//toArray方法整体这个实现类参数的作用是：创建一个指定类型的数组//toArray方法的底层会依次得到流中每一个数据，并把数据放入数组中//toArray方法的返回值是一个装着流里所有数据的数组
/*        String[] arr = list.stream().toArray(new IntFunction<String[]>() {@Overridepublic String[] apply(int value) {return new String[value];}});
*/String[] arr2 = list.stream().toArray(value -> new String[value]);System.out.println(Arrays.toString(arr2));}
}

        以下的代码将演示如何使用 collect() 方法将流中的数据收集到各种集合（List、Set、Map）当中。

package Stream;import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;public class StreamDemo10 {public static void main(String[] args) {/*collect(Collector collector)        收集流中数据，放入集合中(List Set Map)*/ArrayList<String> list = new ArrayList<>();Collections.addAll(list, "张无忌-男-15","周芷若-女-14","赵敏-女-13","张强-男-20","张三丰-男-100","张翠山-女-40","张良-男-35","王二麻子-男-37","谢广坤-男-41");//1.收集到List集合中//需求：收集所有男性List<String> newList = list.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toList());System.out.println(newList);//2.收集到Set集合中//需求：收集所有男性//收集到Set中时，数据会自动去重，且无序Set<String> newSet = list.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toSet());System.out.println(newSet);//3.收集到Map集合中//需求：收集所有男性，键：姓名，值：年龄//toMap:参数一：生成键的规则，参数二：生成值的规则，两个参数都是new Function实现类//第一个new Function<流里面每一个数据的类型,键里面数据的类型>//第二个new Function<流里面每一个数据的类型,值里面数据的类型>//apply方法形参：依次表示流中每一个数据，方法体：生成键/值，返回值：生成的键/值/*注意点：如果要把数据收集到Map当中，那么键是不能有重复的，否则代码会报错*//*Map<String, Integer> newMap = list.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toMap(new Function<String, String>() {@Overridepublic String apply(String s) {//张无忌-男-15//键是名字，对应0索引return s.split("-")[0];}}, new Function<String, Integer>() {@Overridepublic Integer apply(String s) {//张无忌-男-15//值是年龄，对应2索引return Integer.parseInt(s.split("-")[2]);}}));*///改写为Lambda表达式Map<String, Integer> newMap = list.stream().filter(s -> "男".equals(s.split("-")[1])).collect(Collectors.toMap(s -> s.split("-")[0], s -> Integer.parseInt(s.split("-")[2])));System.out.println(newMap);}
}

【练习1】定义一个集合，并添加一些整数1, 2, 3, 4, 5, 6, 7, 8, 9, 10。
要求过滤奇数，只留下偶数，并保存结果。

package Stream;import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;public class StreamDemo11 {public static void main(String[] args) {/*定义一个集合，并添加一些整数1, 2, 3, 4, 5, 6, 7, 8, 9, 10。要求过滤奇数，只留下偶数，并保存结果。*/ArrayList<Integer> list = new ArrayList<>();Collections.addAll(list,1, 2, 3, 4, 5, 6, 7, 8, 9, 10);//过滤奇数，只留下偶数List<Integer> newList = list.stream().filter(n -> n % 2 == 0).collect(Collectors.toList());System.out.println(newList);}
}

【练习2】创建一个 ArrayList 集合，并添加以下字符串，字符串前面是姓名，后面是年龄：
“zhangsan，23” “lisi，24” “wangwu，25”，保留年龄大于等于24岁的人，并把结果放入 Map 中，姓名为键，年龄为值。

package Stream;import java.util.ArrayList;
import java.util.Collections;
import java.util.Map;
import java.util.stream.Collectors;public class StreamDemo12 {public static void main(String[] args) {/*创建一个 ArrayList 集合，并添加以下字符串，字符串前面是姓名，后面是年龄："zhangsan，23" "lisi，24" "wangwu，25"，保留年龄大于等于24岁的人，并把结果放入 Map 中，姓名为键，年龄为值。*/ArrayList<String> list = new ArrayList<>();Collections.addAll(list,"zhangsan，23" ,"lisi，24" ,"wangwu，25");//1.建立流过滤器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])));//2.打印System.out.println(map);}}

【练习3】如下。
在这里插入图片描述

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

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

相关文章

C++入门(01)VisualStudio2022社区版HelloWorld

C++入门(01)VisualStudio2022社区版HelloWorld

文章目录 1. 下载社区版2. 安装3. 启动4. 创建新项目5. C空项目6. 项目名称和位置7. 创建后&#xff0c;出现“新增功能”&#xff0c;关闭即可8. 解决方案和项目9. 新建源文件10. 编辑第一个C程序11. 运行该程序12. Debug文件夹13. 用好Microsoft Learn 1. 下载社区版 访问&a…
阅读更多...
JavaScript 循环分支语句-dowhile循环

JavaScript 循环分支语句-dowhile循环

do/while 循环是 while 循环的变体。该循环会在检查条件是否为真之前执行一次代码块&#xff0c;然后如果条件为真的话&#xff0c;就会重复这个循环。 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta htt…
阅读更多...
网页时装购物系统：Spring Boot框架的创新设计

网页时装购物系统：Spring Boot框架的创新设计

第1章 绪论 1.1背景及意义 随着社会的快速发展&#xff0c;计算机的影响是全面且深入的。人们生活水平的不断提高&#xff0c;日常生活中人们对时装购物系统方面的要求也在不断提高&#xff0c;喜欢购物的人数更是不断增加&#xff0c;使得时装购物系统的开发成为必需而且紧迫的…
阅读更多...
一种非接触式智能垃圾桶设计（论文+源码+实物）

一种非接触式智能垃圾桶设计（论文+源码+实物）

1系统方案设计 通过对需求展开分析&#xff0c;本设计非接触式智能垃圾桶采用STM32F103单片机作为控制器&#xff0c;通过红外传感器实现垃圾桶的满溢检测&#xff0c;通过三个SG90舵机分别控制可回收、不可回收、其他垃圾桶盖的开关&#xff0c;并通过WiFi通信模块将数据信息…
阅读更多...
EmguCV学习笔记 VB.Net 9.2 VideoWriter类

EmguCV学习笔记 VB.Net 9.2 VideoWriter类

版权声明&#xff1a;本文为博主原创文章&#xff0c;转载请在显著位置标明本文出处以及作者网名&#xff0c;未经作者允许不得用于商业目的。 EmguCV是一个基于OpenCV的开源免费的跨平台计算机视觉库,它向C#和VB.NET开发者提供了OpenCV库的大部分功能。 教程VB.net版本请访问…
阅读更多...
c++一个数因子和（快速求解）

c++一个数因子和（快速求解）

void 一个数因子和(int 整数) {//缘由https://ask.csdn.net/questions/1054457#answer_1251715int he 0, j 0; string a "";while (j < 整数)if (!(整数%j))he j, a to_string(j) "";cout << a << "的因子和&#xff1a;" …
阅读更多...
Opencv中的直方图(1)计算反向投影直方图函数calcBackProject()的使用

Opencv中的直方图(1)计算反向投影直方图函数calcBackProject()的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 计算直方图的反向投影。 cv::calcBackProject 函数计算直方图的反向投影。也就是说&#xff0c;类似于 calcHist&#xff0c;在每个位置 (x, y)…
阅读更多...
ITK-高斯滤波

ITK-高斯滤波

作者&#xff1a;翟天保Steven 版权声明&#xff1a;著作权归作者所有&#xff0c;商业转载请联系作者获得授权&#xff0c;非商业转载请注明出处 高斯滤波原理 高斯滤波&#xff08;Gaussian Blur&#xff09;是数字图像处理中常见的一种平滑滤波器&#xff0c;旨在通过模糊处…
阅读更多...
OpenCV结构分析与形状描述符（10）检测并提取轮廓函数findContours()的使用

OpenCV结构分析与形状描述符（10）检测并提取轮廓函数findContours()的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 在二值图像中查找轮廓。 该函数使用算法 253从二值图像中检索轮廓。轮廓是有用的工具&#xff0c;可用于形状分析和对象检测与识别。参见 OpenC…
阅读更多...
Linux下安装MySQL8.0

Linux下安装MySQL8.0

一、安装 1.下载安装包 先创建一个mysql目录&#xff0c;在将压缩包下载到此 # 下载tar包 wget https://dev.mysql.com/get/Downloads/MySQL-8.0/mysql-8.0.20-linux-glibc2.12-x86_64.tar.xz等待下载成功 2.解压mysql8.0安装包 tar xvJf mysql-8.0.20-linux-glibc2.12-x86…
阅读更多...
visual studio 2022更新以后，之前的有些工程编译出错，升级到Visual studio Enterprise 2022 Preview解决

visual studio 2022更新以后，之前的有些工程编译出错，升级到Visual studio Enterprise 2022 Preview解决

系列文章目录 文章目录 系列文章目录前言一、解决方法 前言 今天遇到一个问题&#xff1a;visual studio 2022升级成预览版以后&#xff0c;之前的有些工程编译出错。首先代码、项目设置都没有改变&#xff0c;只是更新了visual studio 2022。 在编译工程时&#xff0c;编译器…
阅读更多...
Mybatis概述

Mybatis概述

目录 MyBatis环境搭建 1.创建一张表和表对应的实体类 2.导入MyBatis jar包&#xff0c;mysql 数据库驱动包 3.创建MyBatis全局配置文件 4.定义接口 5.创建sql映射文件 6.测试MyBatis 读取配置文件 创建SqlSeessionFactory 创建SqlSession 获得接口代理对象 MyBatis-D…
阅读更多...
集成电路学习：什么是RTOS实时操作系统

集成电路学习：什么是RTOS实时操作系统

RTOS&#xff1a;实时操作系统 RTOS&#xff0c;全称Real Time Operating System&#xff0c;即实时操作系统&#xff0c;是一种专为满足实时控制需求而设计的操作系统。它能够在外部事件或数据产生时&#xff0c;以足够快的速度进行处理&#xff0c;并在规定的时间内控制生产过…
阅读更多...
【python】—— Python爬虫实战：爬取珠海市2011-2023年天气数据并保存为CSV文件

【python】—— Python爬虫实战：爬取珠海市2011-2023年天气数据并保存为CSV文件

目录 目标 准备工作 爬取数据的开始时间和结束时间 爬取数据并解析 将数据转换为DataFrame并保存为CSV文件 本文将介绍如何使用Python编写一个简单的爬虫程序，以爬取珠海市2011年至2023年的天气数据，并将这些数据保存为CSV文件。我们将涉及到以下知识点： 使用r…
阅读更多...
VMEMMAP分析

VMEMMAP分析

VMEMMAP分析 前言代码分析memblocks_presentmemory_presentsparse_index_init first_present_section_nrsparse_init_nid__populate_section_memmappfn_to_page和page_to_pfnvmemmap_populatevmemmap_pgd_populatevmemmap_pud_populatevmemmap_alloc_block_zero问&#xff1a;什…
阅读更多...
软件测试永远的家——银行测试，YYDS

软件测试永远的家——银行测试，YYDS

为什么做金融类软件测试举个栗子&#xff0c;银行里的软件测试工程师。横向跟互联网公司里的测试来说&#xff0c;薪资相对稳定&#xff0c;加班少甚至基本没有&#xff0c;业务稳定。实在是测试类岗位中的香饽饽&#xff01; 一、什么是金融行业 金融业是指经营金融商品的特…
阅读更多...
网络安全售前入门09安全服务——安全加固服务

网络安全售前入门09安全服务——安全加固服务

目录 1.服务概述 2.流程及工具 2.1服务流程 2.2服务工具 3.服务内容 ​​​​​​​4.服务方式 ​​​​​​​5.风险规避措施 ​​​​​​​6.服务输出 1.服务概述 安全加固服务是参照风险评估、等保测评、安全检查等工作的结果，基于科学的安全思维方式、长期的安全…
阅读更多...
骨灵冷火！Solon Cloud Gateway 照面发布

骨灵冷火！Solon Cloud Gateway 照面发布

骨灵冷火&#xff0c;是练药的好火哟。极冷&#xff0c;又极热。在冰冻中被烧死&#xff1a;&#xff09; 1、认识 Solon Cloud Gateway Solon Cloud Gateway 是基于 Solon Cloud、Vert.X 和 Solon Rx(reactive-streams) 接口实现。小特点&#xff1a; 纯响应式的接口体验流…
阅读更多...
坐牢第三十六天（QT）

坐牢第三十六天（QT）

自定义QQ界面 wedget.h #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QDebug> //qt中信息调试类 #include <QIcon> //图标类 #include <QPushButton>//按钮类 #include <QLabel> //标签类 #include <QMovie> //动图类…
阅读更多...
树莓派外设驱动WiringPi库

树莓派外设驱动WiringPi库

树莓派外设驱动WiringPi库 文章目录 树莓派外设驱动WiringPi库一、树莓派安装WiringPi库二、WiringPi库的使用方法 一、树莓派安装WiringPi库 wiringPi库其实已经很熟悉了&#xff0c;在香橙派中大量使用过&#xff0c;这个库中集成了很多使用的功能性函数&#xff0c;树莓派安…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023