java8 流Stream 高级使用
Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据。
Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象。
这种风格将要处理的元素集合看作一种流, 流在管道中传输, 并且可以在管道的节点上进行处理, 比如筛选, 排序,聚合等。
熟悉Linux的同学对这种风格一定不陌生,因为它跟Linux的|
管道符的思想如出一辙。上面这段话引用自runoob.com
,但是其教学代码都是基于String列表进行演示,考虑到实际情况百分之80的时候都是对PO、VO进行处理,因此以下通过一个PO进行讲解。
对比起for循环操作list,最大的弊端就是代码太长太乱了,如果涉及3-4张表的操作,也就是涉及多个PO操作,那个括号简直就是俄罗斯套娃
,写到最后真的自己都不知道在写什么
流
+--------------------+ +------+ +------+ +---+ +-------+
| stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
+--------------------+ +------+ +------+ +---+ +-------+
PO代码
以下操作均以UserPo
进行讲解
注 意
文末有:7701页互联网大厂面试题
filter
filter:过滤,就是过滤器,符合条件的通过,不符合条件的过滤掉
// 筛选出成绩不为空的学生人数
count = list.stream().filter(p -> null != p.getScore()).count();
map
map:映射,他将原集合映射成为新的集合,在VO、PO处理的过程中较常见。在本例子中,原集合就是PO集合,新集合可以自定义映射为成绩集合,同时也可以对新集合进行相关操作
// 取出所有学生的成绩
List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());// 将学生姓名集合串成字符串,用逗号分隔
String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));
sorted
sorted:排序,可以根据指定的字段进行排序
// 按学生成绩逆序排序 正序则不需要加.reversed()
filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList());
forEach
forEach:这个应该是最常用的,也就是为每一个元素进行自定义操作]
除了forEach操作会改变原集合的数据,其他的操作均不会改变原集合,这点务必引起注意
collect
collect:聚合,可以用于GroudBy按指定字段分类,也可以用于返回列表或者拼凑字符串
// 按成绩进行归集
Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore()).collect(Collectors.groupingBy(UserPo::getScore));
for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {System.out.println("成绩:" + entry.getKey() + " 人数:" + entry.getValue().size());
}// 返回list
List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
// 返回string用逗号分隔
String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));
statistics
statistics:统计,可以统计中位数,平均值,最大最小值
parallelStream
parallelStream:并行流,可以利用多线程进行流的操作,提升效率。但是其不具备线程传播性,因此使用时需要充分评估是否需要用并行流操作
// 并行流
count = list.parallelStream().filter(p -> null != p.getScore()).count();
完整代码
package com.cmx.tcn.stream;/*** @author: Cai MinXing* @create: 2020-03-25 18:17**/
public class UserPo {private String name;private Double score;public UserPo(String name, Double score) {this.name = name;this.score = score;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Double getScore() {return score;}public void setScore(Double score) {this.score = score;}@Overridepublic String toString() {return "UserPo{" +"name='" + name + '\'' +", score=" + score +'}';}
}
package com.cmx.tcn.stream;import java.util.ArrayList;
import java.util.Comparator;
import java.util.DoubleSummaryStatistics;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;/*** @author: Cai MinXing* @create: 2020-03-25 18:15**/
public class StreamTest {// +--------------------+ +------+ +------+ +---+ +-------+
// | stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
// +--------------------+ +------+ +------+ +---+ +-------+public static void main(String args[]){List<UserPo> list = new ArrayList<>();list.add(new UserPo("小一", 10.d));list.add(new UserPo("小五", 50.d));list.add(new UserPo("小六", 60.d));list.add(new UserPo("小6", 60.d));list.add(new UserPo("小空", null));list.add(new UserPo("小九", 90.d));long count = 0;List<UserPo> filterList = null;// filter 过滤器的使用// 筛选出成绩不为空的学生人数count = list.stream().filter(p -> null != p.getScore()).count();System.out.println("参加考试的学生人数:" + count);// collect// 筛选出成绩不为空的学生集合filterList = list.stream().filter(p -> null != p.getScore()).collect(Collectors.toList());System.out.println("参加考试的学生信息:");filterList.stream().forEach(System.out::println);// map 将集合映射为另外一个集合// 取出所有学生的成绩List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());System.out.println("所有学生的成绩集合:" + scoreList);// 将学生姓名集合串成字符串,用逗号分隔String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));System.out.println("所有学生的姓名字符串:" + nameString);// sorted排序// 按学生成绩逆序排序 正序则不需要加.reversed()filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList());System.out.println("所有学生的成绩集合,逆序排序:");filterList.stream().forEach(System.out::println);System.out.println("按学生成绩归集:");Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore()).collect(Collectors.groupingBy(UserPo::getScore));for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {System.out.println("成绩:" + entry.getKey() + " 人数:" + entry.getValue().size());}// forEachfilterList.stream().forEach(p -> p.setScore(p.getScore() + 10));System.out.println("及格人数太少,给每个人加10分");filterList.stream().forEach(System.out::println);// countcount = filterList.stream().filter(p -> p.getScore() >= 60).count();System.out.println("最后及格人数" + count);DoubleSummaryStatistics statistics = filterList.stream().mapToDouble(p -> p.getScore()).summaryStatistics();System.out.println("列表中最大的数 : " + statistics.getMax());System.out.println("列表中最小的数 : " + statistics.getMin());System.out.println("所有数之和 : " + statistics.getSum());System.out.println("平均数 : " + statistics.getAverage());// 并行流 使用count = list.parallelStream().filter(p -> null != p.getScore()).count();System.out.println("并行流处理参加考试的学生人数:" + count);}}
java8 流Stream 高级使用相关推荐
- 探索Java8——流(Stream)
文章目录 什么是流 流简介 流与集合 只能遍历一次 外部迭代与内部迭代 流操作 中间操作 终端操作 使用流 收集器简介 并行流 将顺序流转换为并行流 集合是Java中使用最多的API.要是没有集合,还 ...
- Java8流Stream的创建和操作
1. 流的创建方法 import java.util.stream.*;public class StreamOf {public static void main(String[] args) {S ...
- Java8特性 stream流常用方法
Java8特性 stream流常用方法 Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据. Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方 ...
- Java8中Stream流对集合操作
java8中Stream流引入函数式编程思想,主要配合各种接口.lambda表达式.方法引用等方式,为集合的遍历.过滤.映射等提供非常"优雅"的操作方式. Student.java ...
- Java8 的 Stream 流式操作之王者归来
相对于Java8之前的Java的相关操作简直是天差地别,Java8 的流式操作的出现,也很大程度上改变了开发者对于Java的繁琐的操作的印象,从此,Java也走向了函数式编程的道路! 1 流的创建 1 ...
- Java8种Stream流相关操作——集合的筛选、归约、分组、聚合
过滤.筛选 filter skip /*** 过滤 筛选*/@Testpublic void test2(){List<String> list = Arrays.asList(&qu ...
- Java8的 Stream 流的各种用法
Java8 的 Stream 流的各种用法 什么是Stream 1. Stream可以由数组或集合创建,对流的操作分为两种 2. Stream的特性 3. Stream可以通过集合数组创建 4. st ...
- java8中stream流解决两个list合并问题
当我们遇到需要将两个list合并成一个list实体的时候,可以使用java8的stream流来解决,以下是我的一个小demo,可供大家参考学习. public ResultDto listBalanc ...
- java8的stream流的使用
package com.fan.yygh.hosp;import org.junit.jupiter.api.Test;import java.util.*; import java.util.str ...
最新文章
- BizTalk 开发小技巧-Custom XSLT复杂mapping的简单实现
- 上标3下标6算法_图解堆排序算法
- linux系统加硬盘容量,Linux系统扩展硬盘空间
- JavaScript(js)/上
- 平方剩余(例题+详解+代码模板)
- java servletlis_Java学习(六)servlet 的引入
- Android - Activity 生命周期
- 请求之前~HttpHandler实现媒体文件和图像文件的盗链
- qt设置窗口不在任务栏上显示
- [算法导论]哈希表 @ Python
- Windbg程序调试系列1-常用命令说明Mex扩展使用总结
- 回顾历史5次经济衰退时期:这一次可能会有何不同?
- 淘宝奇葩店铺:一个人的皇冠店|视频
- Robcup2D足球学习记录【2020.01.18】
- 微信视频号自助下单刷平台
- 概要设计说明书(实例)
- java bitwise_java – Bitwise不对一串位操作
- 简单的Django系统模板
- oracle存小数用 number(m,n)
- 集合类对象的遍历处理办法