首页 > 编程语言 > java8 (jdk 1.8) 新特性——Stream ApI

java8 (jdk 1.8) 新特性——Stream ApI

时间:2022-11-22 09:57:35浏览次数:64  
标签:jdk Stream userInfoList 1.8 collect add UserInfo new stream

在java8 中,有两个最重要的改变,一个就是之前了解的Lmbda java8 (jdk 1.8) 新特性——Lambda ,还有一个就是Stream Api 

1. 什么是Stream API 

简单来说就是一个类库,里边有一些方法方便我们对集合数据进行操作,就好像使用 SQL 语句进行操作数据库一样

优点就是,使我们代码简洁更高效的处理数据,高效!! 

官方java8 Api中文文档 在公众号内 回复关键字 【文档】 获取

一个完成的stream 流操作包含以下内容

  • 一个数据源,数据源可以是集合,数组

  • 中间链的操作 (比如  过滤, 去重,排序 等等)

  • 终止操作,产生一个结果(比如重新收集成集合)

 

例如:

        List<UserInfo> userInfoList =new ArrayList<>();
        userInfoList.add(new UserInfo(1,"张三",23));
        userInfoList.add(new UserInfo(2,"李四",25));
        userInfoList.add(new UserInfo(3,"王五",24));
        userInfoList.add(new UserInfo(4,"赵六",26));
        
        List<String> collect = userInfoList.stream().filter(info->info.getAge()>=25).map(UserInfo::getName).collect(Collectors.toList());

 

 

 

2.  Stream 实例化

  • 通过集合创建顺序流    . stream  【常用

  Stream<UserInfo> stream = userInfoList.stream();
  • 通过集合创建并行流    . stream

Stream<UserInfo> parallelStream = userInfoList.parallelStream();

  这两个流的区别在初篇也有简单的介绍:java8 (jdk 1.8) 新特性 ——初步认识

 

  • 通过数组 

  int[]  ids ={1,2,3,4,5};
        IntStream stream = Arrays.stream(ids);

 

  •    Stream.of()   【常用】
 Stream<Integer> ids1 = Stream.of(1,2,3,4,5);

 

2.  常用操作 (重点)

Api中常用的操作有很多,这边就列举一些工作中会使用到的

数据源:

   List<UserInfo> userInfoList =new ArrayList<>();
        userInfoList.add(new UserInfo(1,"张三",23));
        userInfoList.add(new UserInfo(2,"李四",25));
        userInfoList.add(new UserInfo(3,null,24));
        userInfoList.add(new UserInfo(4,"赵六",26));
  •   过滤 (filter) 

过滤获取名字不为空的数据

userInfoList.stream().filter(info -> Objects.nonNull(info.getName())).forEach(System.out::println);

  

 

 

  •  获取其中一个属性集 (map)

  获取所有用户的名字集

userInfoList.stream().map(UserInfo::getName).forEach(System.out::println);

 

如果加上过滤 不为null数据

先过滤后过滤返回的结果集都是一样的

先map 后 filter

 userInfoList.stream().map(UserInfo::getName).filter(Objects::nonNull).forEach(System.out::println);

   先filter后 map ,代码量明显增多,所以在操作前可以思考一下,哪一种更好一点

 userInfoList.stream().filter(info -> Objects.nonNull(info.getName())).map(UserInfo::getName).forEach(System.out::println);

  

 

 

 

  • 排序 (sorted)

 

 

 

按照年龄排序 (默认正序,从小到大)

 userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge)).forEach(System.out::println);

 

 

 倒序(从大到小),加个reversed() 就好了

   userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge).reversed()).forEach(System.out::println);

  

 

 

 

  • 计算 (reduce)

出现金额计算的时候,一般电商,库存系统 经常用得到
这边演示我就不新建一个类了(偷懒),把年龄类型直接改成 BigDecimal 注意:跟钱相关的类型都得用 BigDecimal  不要用double,精度会丢失,这可是钱,计算丢了一毛钱,财务都得奔溃

 

 

 

 

 List<UserInfo> userInfoList =new ArrayList<>();
        userInfoList.add(new UserInfo(1,"张三",new BigDecimal("32")));
        userInfoList.add(new UserInfo(2,"李四",new BigDecimal("50")));
        userInfoList.add(new UserInfo(3,null,new BigDecimal("40")));
        userInfoList.add(new UserInfo(4,"赵六",new BigDecimal("30")));

        BigDecimal bigDecimal = userInfoList.stream().map(UserInfo::getAge).reduce(BigDecimal::add).orElse(new BigDecimal("0"));

        System.out.println(bigDecimal);

  

 

 

 

 

  • 转Map 集合  

将数据源转为名称,年龄map

 Map<String, Integer> collect = userInfoList.stream().collect(Collectors.toMap(UserInfo::getName, UserInfo::getAge));

 

collect:就是将中间链操作后的结果进行处理 ,前面我们为了演示,都是进行forEach 进行打印输出,在工作中,都是用collect 进行收集成新的集合,或者其他数据形式

就比如: 获取所有姓名集合

 

List<String> collect = userInfoList.stream().map(UserInfo::getName).collect(Collectors.toList());

  

有这么多种处理结果的方式

 

 

 

用的最多的就是 

1.   .collect(Collectors.toList())

2.   .collect(Collectors.toMap(。。。。。))

3.   .collect(Collectors.groupingBy(。。。。。)) 

 

 

  • 分组   groupingBy 

按照年龄分组

     List<UserInfo> userInfoList =new ArrayList<>();
        userInfoList.add(new UserInfo(1,"张三",23));
        userInfoList.add(new UserInfo(2,"李四",23));
        userInfoList.add(new UserInfo(3,null,24));
        userInfoList.add(new UserInfo(4,"赵六",26));

        Map<Integer, List<UserInfo>> collect = userInfoList.stream().collect(Collectors.groupingBy(UserInfo::getAge));

        collect.forEach((k,v) -> System.out.println("键:"+k+"......值:"+v));

  

 

 

其他API也很常用,建议随时看看Api文档,有个印象,遇到有需要使用的时候就能快速定位了

最后!! 记得公众号内回复 关键字【文档】 获取 java8 api 中英文,双倍快乐

 

 

 

 

 

 

java8 (jdk 1.8) 新特性—— 方法引用+构造器引用

java8 (jdk 1.8) 新特性——Lambda

java8 (jdk 1.8) 新特性 ——初步认识

 

标签:jdk,Stream,userInfoList,1.8,collect,add,UserInfo,new,stream
From: https://www.cnblogs.com/zeroll/p/16914177.html

相关文章

  • Stream流
    Stream流引入Lambda表达式,基于Lambda所带来的函数式编程,又引入了一个全新的Stream概念,用于解决集合类库既有的鼻端。(Lambda表达式详解在上篇博客内容)现有一个需求:将list......
  • JDK 的安装
    1.官网下载  https://www.oracle.com/java/technologies/downloads/#jdk17-windows  2.安装 最好不要用中文路径 直接下一步下一步就可以了   3.新建H......
  • Java配置jdk环境变量
     配置:1、进入系统环境变量设置。  2、点击环境变量 3、如图所示:  4、如图所示:   5、点击确定退出配置界面检验:1、win+r,输入cmd,点击确定。 ......
  • 11.21.8
    #include<stdio.h>#include<string.h>intmain(){intl; chara[1000],b[1000]; gets(a); l=strlen(a); inti,j,n; for(i=0,j=0;i<l;i++) {if(a[i]!=''){b[j]=a[......
  • 温故而知新——jdk8后新增的时间类
    jdk8后新增的时间类:LocalTimeLocalDateLocalDateTime:LocalDateTime可以转化成其他2类时间:三个工具类Duration:用于计算2个“时间间隔”(秒,纳秒)Period:用于计算2......
  • HTTP/2 stream 1 was not closed cleanly before end of the underlying stream
    报错日志leepandar@localhostant-design-vue-jeecg%yarninstallyarninstallv1.22.19[1/4]......
  • OutputStreamWriter
    OutputStreamWriter/**Copyright(c)1996,2013,Oracleand/oritsaffiliates.Allrightsreserved.*ORACLEPROPRIETARY/CONFIDENTIAL.Useissubjecttoli......
  • nginx中request_time和upstream_response_time详解
    背景 最近监控报警有短暂的502,赶紧分析问题原因,查看nginx的access_log发现短暂报警的request_time比较大,但是upstream_response_time有2个值,一个比较小,一个比较大,日志如......
  • java File类与文件输入/输出流:FileInputStream与FileOutputStream
    javaFile类与文件输入/输出流File类File类是java.io包中唯一代表磁盘文件本身的类,该类主要用于文件和目录的创建、文件的查找和文件的删除等。文件的创建与删除1.Fi......
  • 【Java】JDK5.0新增的创建多线程的方式:实现Callable接口,使用线程池
    1.实现Callable接口方式和实现Runnable接口相比call()可以有返回值。call()可以抛出异常,被外面的操作捕获,获取异常信息。Callable是支持泛型的。实现Callable接口......