JDK8都10岁了，你还在用for循环遍历list吗？

转x33g5p2x  于2022-08-17 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(550)

简介

Java 8 API添加了一个新的抽象称为流Stream，可以让你以一种声明的方式处理数据。

Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象。这种风格将要处理的元素集合看作一种流， 流在管道中传输， 并且可以在管道的节点上进行处理， 比如筛选， 排序，聚合等。

熟悉Linux的同学对这种风格一定不陌生，因为它跟Linux的|管道符的思想如出一辙。上面这段话引用自runoob.com，但是其教学代码都是基于String列表进行演示，考虑到实际情况百分之80的时候都是对PO、VO进行处理，因此以下通过一个PO进行讲解。

对比起for循环操作list，最大的弊端就是代码太长太乱了，如果涉及3-4张表的操作，也就是涉及多个PO操作，那个括号简直就是俄罗斯套娃，写到最后真的自己都不知道在写什么

流

  1. +--------------------+       +------+   +------+   +---+   +-------+
  2. | stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
  3. +--------------------+       +------+   +------+   +---+   +-------+

PO代码

  1. public class UserPo {
  2.     private String name;
  3.     private Double score;
  4.     
  5.     // 省略构造函数及getter、setter
  6. }

以下操作均以UserPo进行讲解

filter

filter：过滤，就是过滤器，符合条件的通过，不符合条件的过滤掉

  1. // 筛选出成绩不为空的学生人数
  2. count = list.stream().filter(p -> null != p.getScore()).count();

map

map：映射，他将原集合映射成为新的集合，在VO、PO处理的过程中较常见。在本例子中，原集合就是PO集合，新集合可以自定义映射为成绩集合，同时也可以对新集合进行相关操作

  1. // 取出所有学生的成绩
  2. List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
  4. // 将学生姓名集合串成字符串，用逗号分隔
  5. String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));

sorted

sorted：排序，可以根据指定的字段进行排序

  1. // 按学生成绩逆序排序 正序则不需要加.reversed()
  2. filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList());

forEach

forEach：这个应该是最常用的，也就是为每一个元素进行自定义操作
除了forEach操作会改变原集合的数据，其他的操作均不会改变原集合，这点务必引起注意

  1. // 学生成绩太差了，及格率太低，给每个学生加10分，放个水
  2. // forEach
  3. filterList.stream().forEach(p -> p.setScore(p.getScore() + 10));

collect

collect：聚合，可以用于GroudBy按指定字段分类，也可以用于返回列表或者拼凑字符串

  1. // 按成绩进行归集
  2. Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore()).collect(Collectors.groupingBy(UserPo::getScore));
  3. for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {
  4.     System.out.println("成绩：" + entry.getKey() + " 人数：" + entry.getValue().size());
  5. }
  7. // 返回list
  8. List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
  9. // 返回string用逗号分隔
  10. String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));

statistics

statistics：统计，可以统计中位数，平均值，最大最小值

  1. DoubleSummaryStatistics statistics = filterList.stream().mapToDouble(p -> p.getScore()).summaryStatistics();
  2. System.out.println("列表中最大的数 : " + statistics.getMax());
  3. System.out.println("列表中最小的数 : " + statistics.getMin());
  4. System.out.println("所有数之和 : " + statistics.getSum());
  5. System.out.println("平均数 : " + statistics.getAverage());

parallelStream

parallelStream：并行流，可以利用多线程进行流的操作，提升效率。但是其不具备线程传播性，因此使用时需要充分评估是否需要用并行流操作

  1. // 并行流
  2. count = list.parallelStream().filter(p -> null != p.getScore()).count();

完整代码

  1. package com.cmx.tcn.stream;
  3. /**
  4.  * @author: Cai MinXing
  5.  **/
  6. public class UserPo {
  7.     private String name;
  8.     private Double score;
  10.     public UserPo(String name, Double score) {
  11.         this.name = name;
  12.         this.score = score;
  13.     }
  15.     public String getName() {
  16.         return name;
  17.     }
  19.     public void setName(String name) {
  20.         this.name = name;
  21.     }
  23.     public Double getScore() {
  24.         return score;
  25.     }
  27.     public void setScore(Double score) {
  28.         this.score = score;
  29.     }
  31.     @Override
  32.     public String toString() {
  33.         return "UserPo{" +
  34.                 "name='" + name + '\'' +
  35.                 ", score=" + score +
  36.                 '}';
  37.     }
  38. }
  1. package com.cmx.tcn.stream;
  3. import java.util.ArrayList;
  4. import java.util.Comparator;
  5. import java.util.DoubleSummaryStatistics;
  6. import java.util.List;
  7. import java.util.Map;
  8. import java.util.stream.Collectors;
  10. /**
  11.  * @author: Cai MinXing
  12.  * @create: 2020-03-25 18:15
  13.  **/
  14. public class StreamTest {
  16. //    +--------------------+       +------+   +------+   +---+   +-------+
  17. //    | stream of elements +-----> |filter+-> |sorted+-> |map+-> |collect|
  18. //    +--------------------+       +------+   +------+   +---+   +-------+
  20.     public static void main(String args[]){
  22.         List<UserPo> list = new ArrayList<>();
  23.         list.add(new UserPo("小一", 10.d));
  24.         list.add(new UserPo("小五", 50.d));
  25.         list.add(new UserPo("小六", 60.d));
  26.         list.add(new UserPo("小6", 60.d));
  27.         list.add(new UserPo("小空", null));
  28.         list.add(new UserPo("小九", 90.d));
  30.         long count = 0;
  31.         List<UserPo> filterList = null;
  33.         // filter 过滤器的使用
  34.         // 筛选出成绩不为空的学生人数
  35.         count = list.stream().filter(p -> null != p.getScore()).count();
  36.         System.out.println("参加考试的学生人数：" + count);
  38.         // collect
  39.         // 筛选出成绩不为空的学生集合
  40.         filterList = list.stream().filter(p -> null != p.getScore()).collect(Collectors.toList());
  41.         System.out.println("参加考试的学生信息：");
  42.         filterList.stream().forEach(System.out::println);
  44.         // map 将集合映射为另外一个集合
  45.         // 取出所有学生的成绩
  46.         List<Double> scoreList = list.stream().map(p -> p.getScore()).collect(Collectors.toList());
  47.         System.out.println("所有学生的成绩集合：" + scoreList);
  49.         // 将学生姓名集合串成字符串，用逗号分隔
  50.         String nameString = list.stream().map(p -> p.getName()).collect(Collectors.joining(","));
  51.         System.out.println("所有学生的姓名字符串：" + nameString);
  53.         // sorted排序
  54.         // 按学生成绩逆序排序 正序则不需要加.reversed()
  55.         filterList = list.stream().filter(p -> null != p.getScore()).sorted(Comparator.comparing(UserPo::getScore).reversed()).collect(Collectors.toList());
  56.         System.out.println("所有学生的成绩集合，逆序排序：");
  57.         filterList.stream().forEach(System.out::println);
  59.         System.out.println("按学生成绩归集：");
  60.         Map<Double, List<UserPo>> groupByScoreMap = list.stream().filter(p -> null != p.getScore())
  61.                 .collect(Collectors.groupingBy(UserPo::getScore));
  62.         for (Map.Entry<Double, List<UserPo>> entry : groupByScoreMap.entrySet()) {
  63.             System.out.println("成绩：" + entry.getKey() + " 人数：" + entry.getValue().size());
  64.         }
  66.         // forEach
  67.         filterList.stream().forEach(p -> p.setScore(p.getScore() + 10));
  68.         System.out.println("及格人数太少，给每个人加10分");
  69.         filterList.stream().forEach(System.out::println);
  71.         // count
  72.         count = filterList.stream().filter(p -> p.getScore() >= 60).count();
  73.         System.out.println("最后及格人数" + count);
  75.         DoubleSummaryStatistics statistics = filterList.stream().mapToDouble(p -> p.getScore()).summaryStatistics();
  76.         System.out.println("列表中最大的数 : " + statistics.getMax());
  77.         System.out.println("列表中最小的数 : " + statistics.getMin());
  78.         System.out.println("所有数之和 : " + statistics.getSum());
  79.         System.out.println("平均数 : " + statistics.getAverage());
  81.         // 并行流 使用
  82.         count = list.parallelStream().filter(p -> null != p.getScore()).count();
  83.         System.out.println("并行流处理参加考试的学生人数：" + count);
  85.     }
  87. }

来源：bugpool.blog.csdn.net/article/details/105122681

推荐3个原创springboot+Vue项目，有完整视频讲解与文档和源码：

【dailyhub】【实战】带你从0搭建一个Springboot+elasticsearch+canal的完整项目
  • 视频讲解：https://www.bilibili.com/video/BV1Jq4y1w7Bc/
  • 完整开发文档：https://www.zhuawaba.com/post/124
  • 线上演示：https://www.zhuawaba.com/dailyhub
【VueAdmin】手把手教你开发SpringBoot+Jwt+Vue的前后端分离后台管理系统
  • 视频讲解：https://www.bilibili.com/video/BV1af4y1s7Wh/
  • 完整开发文档前端：https://www.zhuawaba.com/post/18
  • 完整开发文档后端：https://www.zhuawaba.com/post/19
  • 线上演示：https://www.markerhub.com/vueadmin/
【VueBlog】基于SpringBoot+Vue开发的前后端分离博客项目完整教学
  • 视频讲解：https://www.bilibili.com/video/BV1PQ4y1P7hZ
  • 完整开发文档：https://www.zhuawaba.com/post/17

关注我，学Java

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/MarkerHub/article/details/126026165

内容来源于网络，如有侵权，请联系作者删除！

JavaLambdaFilterStreames

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com