Java8Stream(高效处理集合数据)

简介: Java8Stream(高效处理集合数据)

🔖什么是Stream?


▐ 概述

•  这里的Stream流与之前JavaSE中的IO流是完全不同的两个概念,不要混淆!

•  IO流是:输入输出文件内容

•  java8stream是:处理数据集合,遍历数据集的高级迭代器,可以对数组、集合类进行各种操作.


•  Stream处理数据大体过程:


   数组/集合类 ----> 流 ----> 各种操作 ( 如过滤、排序 ) ----> 最终结果 ( 数组/集合类 )    


🔖获取流


▐ 获取Stream流方式常用的有三种:

•  使用Collection接口下的stream()  对应集合

•  使用Arrays中的stream()方法,将数组转成流   对应数组

•  使用Stream中的静态方法:of()

⌨️代码演示

1.  使用Collection接口下的stream()

        ArrayList<Integer> list = new ArrayList();
        list.add(1);
        list.add(2);
        list.add(3);
        Stream<Integer> stream = list.stream();

2.  使用Arrays中的stream()方法,将数组转成流

        Integer[] array =new Integer[]{1,2,3,4,5};
        Stream<Integer> stream = Arrays.stream(array);

3.  使用Stream中的静态方法:of()

Stream<Integer> stream1 = Stream.of(1, 2, 3, 4);

🔖流操作

•  流操作分为中间操作和终端操作

•  对某一数据处理的过程为:数据源 ---> 中间操纵 ---> 终端操作 ---> 结果

🏷️中间操作

常用操作有:

 filter :      过滤流中的某些元素

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .filter((e)->{                 //中间操作(过滤)
                    return e>3;                //过滤条件
                })
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[4, 5, 4]

 sorted  排序(流中元素需要实现Comparable接口)

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .sorted((o1,o2)->{             //中间操作(排序)
                    return o2-o1;              //逆序
                })
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[5, 4, 4, 3, 2, 2, 1]

•  distinct去掉重复元素

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .distinct()                    //中间操作(去掉重复元素)
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[1, 2, 3, 4, 5]

limit(n) 获取n个元素

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .limit(4)                       //中间操作(获取n个元素)
                .collect(Collectors.toList());  //终端操作(返回一个集合)
        System.out.println(list);               //输出结果:[1, 2, 3, 4]

•  skip(n) 跳过n个元素,配合limit(n)可以实现分页

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .skip(3)                        //中间操作(跳过n个元素)
                .limit(4)                       //中间操作(获取n个元素)
                .collect(Collectors.toList());  //终端操作(返回一个集合)
        System.out.println(list);               //输出结果:[4, 5, 2, 4]

•  map() :  将其映射成一个新的元素

▐ 可以对数据进行多次中间操作

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .distinct()                      //中间操作(去掉重复元素) 12345
                .sorted((o1,o2)->{
                    return o2-o1;
                })                               //中间操作(排序,逆序)   54321
                .limit(3)                        //中间操作(获取3个元素)  543
                .collect(Collectors.toList());   //终端操作(返回一个集合)
        System.out.println(list);                //输出结果:[5, 4, 3]

🏷️终端操作


•  终端操作通常返回的是我们需要的结果(如数组、集合、单值)

常用操作有:

▐ 代码详细演示:

 forEach:遍历流中的元素

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Arrays.stream(array)
                .forEach((e) -> {
                    System.out.print(e);//遍历:1234524
                });

•  collect:     将流中的元素倒入一个集合, Collection或Map

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list =Arrays.stream(array)
                .distinct()
                .collect(Collectors.toList());//将处理后的流元素重新导入一个集合中
        System.out.println(list);//[1, 2, 3, 4, 5]

   Min:     返回流中元素最小值

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Integer min=Arrays.stream(array)
                .distinct()
                .max((o1,o2)->{
                    return o2-o1; //o2-o1返回min  o1-o2返回max
                })
                .get();           //.get不能忘
        System.out.println(min);     //结果输出:1

                                                                                                                   ( .get 不要忘记哦!)


•    Max        返回流中元素最大值


//模仿上述求最小值,只需将o2-o1改为o1-o2即可

•   count:     返回流中元素的总个数

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        long count=Arrays.stream(array)
                .distinct()   //中间操作(去重) 12345
                .count();     //终端操作(流中元素个数)
        System.out.println(count);//结果输出:5

                                                                                                        ( 返回值是long )


•  Reduce:   所有元素求和

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Integer sum=Arrays.stream(array)
                .distinct()
                .reduce((o1,o2)->{
                    return o1+o2;
                })                   //去重后求和 1+2+3+4+5
                .get();
        System.out.println(sum);     //结果输出:15

                                                                                                               ( .get 不要忘记哦!)  


 anyMatch:接收一个Predicate函数,只要流中有一个元素满足条件则返回true,否则返回false

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        boolean anyMatch=Arrays.stream(array)
                .anyMatch((e)->{
                    return e>4;   //流中只要有一个元素满足条件就返回true
                });
        System.out.println(anyMatch); //结果输出:true

allMatch:  接收一个Predicate函数,当流中每个元素都符合条件时才返回true,否则返回false

       Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        boolean allMatch=Arrays.stream(array)
                .allMatch((e)->{
                    return e>1;   //流中所有元素满足条件才返回true
                });
        System.out.println(allMatch); //结果输出:false

findFirst:  返回流中第一个元素

        Integer[] array = new Integer[]{6, 2, 3, 4, 5, 2, 4};
        Integer first=Arrays.stream(array)
                .findFirst()
                .get();
        System.out.println(first); //结果输出:6

 toArray: 将流中的元素倒入一个数组

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
         Object[] a=Arrays.stream(array)
                .distinct()
                .toArray();     //将处理后的流元素重新导入一个数组中
        System.out.println(Arrays.toString(a));//[1, 2, 3, 4, 5]

▐ 结语:

      希望这篇关于java8中Stream流的介绍能对大家有所帮助,欢迎大佬们留言或私信与我交流~~学海漫浩浩,我亦苦作舟!大家一起学习,一起进步!


相关文章
|
2月前
|
存储 算法 安全
Java集合框架:理解类型多样性与限制
总之,在 Java 题材中正确地应对多样化与约束条件要求开发人员深入理解面向对象原则、范式编程思想以及JVM工作机理等核心知识点。通过精心设计与周密规划能够有效地利用 Java 高级特征打造出既健壮又灵活易维护系统软件产品。
97 7
|
3月前
|
Java 大数据 API
Java Stream API:现代集合处理与函数式编程
Java Stream API:现代集合处理与函数式编程
253 100
|
3月前
|
Java API 数据处理
Java Stream API:现代集合处理新方式
Java Stream API:现代集合处理新方式
286 101
|
3月前
|
存储 Java Go
对比Java学习Go——函数、集合和OOP
Go语言的函数支持声明与调用,具备多返回值、命名返回值等特性,结合`func`关键字与类型后置语法,使函数定义简洁直观。函数可作为一等公民传递、赋值或作为参数,支持匿名函数与闭包。Go通过组合与接口实现面向对象编程,结构体定义数据,方法定义行为,接口实现多态,体现了Go语言的简洁与高效设计。
|
3月前
|
Java API 开发工具
【Azure Developer】Java代码实现获取Azure 资源的指标数据却报错 "invalid time interval input"
在使用 Java 调用虚拟机 API 获取指标数据时,因本地时区设置非 UTC,导致时间格式解析错误。解决方法是在代码中手动指定时区为 UTC,使用 `ZoneOffset.ofHours(0)` 并结合 `withOffsetSameInstant` 方法进行时区转换,从而避免因时区差异引发的时间格式问题。
211 3
|
3月前
|
算法 Java
50道java集合面试题
50道 java 集合面试题
|
3月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
248 16
|
4月前
|
存储 NoSQL Java
Java Stream API:集合操作与并行处理
Stream API 是 Java 8 提供的集合处理工具,通过声明式编程简化数据操作。它支持链式调用、延迟执行和并行处理,能够高效实现过滤、转换、聚合等操作,提升代码可读性和性能。
|
4月前
|
存储 缓存 安全
Java集合框架(三):Map体系与ConcurrentHashMap
本文深入解析Java中Map接口体系及其实现类,包括HashMap、ConcurrentHashMap等的工作原理与线程安全机制。内容涵盖哈希冲突解决、扩容策略、并发优化,以及不同Map实现的适用场景,助你掌握高并发编程核心技巧。
|
4月前
|
存储 缓存 安全
Java集合框架(二):Set接口与哈希表原理
本文深入解析Java中Set集合的工作原理及其实现机制,涵盖HashSet、LinkedHashSet和TreeSet三大实现类。从Set接口的特性出发,对比List理解去重机制,并详解哈希表原理、hashCode与equals方法的作用。进一步剖析HashSet的底层HashMap实现、LinkedHashSet的双向链表维护顺序特性,以及TreeSet基于红黑树的排序功能。文章还包含性能对比、自定义对象去重、集合运算实战和线程安全方案,帮助读者全面掌握Set的应用与选择策略。
272 23