高考报名时间2022年11月1日还剩 天 距离2023年6月7日高考还有 天
栏目分类:
子分类:
返回
名师互学网用户登录
名师互学网
快速导航关闭
当前搜索
当前分类
前沿技术 软件开发 系统运维 产品运营 生活办公 面试经验 考试题库
子分类
人工智能 大数据 云计算 区块链 物联网 深度学习 机器学习 NLP 计算机视觉 语音识别 其他 大数据系统 数据可视化 数据挖掘与分析 其他 Docker/k8s 虚拟化 云平台 其他 基本原理 数字货币 智能合约 EOS应用 其他 通讯技术 嵌入式开发 单片机 物联网应用 HarmonyOS 其他 后端开发 Web开发 移动开发 游戏开发 Python Java 架构设计 C/C++/C# PHP .Net Go语言 R语言
实用工具
学习工具 小学数学练习 字帖生成 在线画板 函数绘制 拼音字母表 在线词典 黄历查询 亲戚关系计算 安全期计算 中国历史 Excel函数 模拟请求 json格式化 浏览器指纹
热门搜索
路由器设置 木托盘 宝塔面板 儿童python教程 心情低落 朋友圈 vim 双一流学科 专升本 我的学校 日记学校 西点培训学校 汽修学校 情书 化妆学校 塔沟武校 异形模板 西南大学排名 最精辟人生短句 6步教你追回被骗的钱 南昌大学排名 清朝十二帝 北京印刷学院排名 北方工业大学排名 北京航空航天大学排名 首都经济贸易大学排名 中国传媒大学排名 首都师范大学排名 中国地质大学(北京)排名 北京信息科技大学排名
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java8新特性——Stream流

Java 更新时间： 发布时间： IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java8新特性——Stream流

文章目录

什么是Stream流

创建Stream流

使用Stream流（常用API）

fliter()：按条件进行过滤

limit()：按个数进行取出

distinct()：去重

skip()：跳过前N个流，开始截取

map()：对集合元素逐个进行函数操作，映射成全新的一个集合

flatmap()：接收一个函数作为参数，将流中的值进行函数操作后，然后把所有流连接成一个流

sorted()：排序，可自定义排序

Collectors.groupingBy:按条件进行分组

查找匹配

reduce()：将流中的数据反复结合起来得到一个值

终止操作

查找与匹配

归约

Collector 接口中方法

什么是Stream流

在《java8 in action》书中，作者说目前我们在几乎所有开发中都会用到集合，但是目前集合在程序开发中的表现还不够完美，比如你利用集合处理大量数据时，你不得不面对性能问题，不得不考虑进行并行代码的编写，这些工作都是比较繁重的，于是作者便创造了Stream 流。相比较Collection集合来说，Stream在开发中就具有许多独特的优点。

  • 以声明式的方式处理数据集合——更简洁，更易读
  • 可复合——更灵活
  • 可并行——无需写任何多线程代码，Stream API自动处理这些问题，性能更好

注意：map是无法使用stream流，可以将key-value单独取出来做流处理

创建Stream流

有三种方式创建流，静态方法，集合流（常用），数组流。

        //静态方法
        Stream.of("start",1,2,3,"end");
        //集合流
        ArrayList arrayList = new ArrayList<>();
        arrayList.stream();
        //数组流
        int[] ints = new int[5];
        Arrays.stream(ints); 

使用Stream流（常用API） 

首先创建一个Student类测试
 

public class Student {
    private String name;
    public Student(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Override
    public String toString() {
        return "Student{" +
                "name='" + name + ''' +
                '}';
    }
}
 

  List employeeList = Arrays.asList(
                new Employee(101,"杰斯",29,10000.02),
                new Employee(101,"杰斯",29,20000.02),
                new Employee(102,"莫甘娜",19,500.02),
                new Employee(103,"剑姬",31,4399.02),
                new Employee(104,"刀妹",25,7777.02),
                new Employee(105,"提莫",44,100.02)
        );
 

fliter()：按条件进行过滤 

employeeList
.stream()
.filter(x->x.getAge()>20)
.forEach(System.out::println);
 

取出年龄大于20岁的结果
 

 
 
------------按条件过滤-------------
 Employee{id=101, name='杰斯', age=29, salary=10000.02}
 Employee{id=101, name='杰斯', age=29, salary=20000.02}
 Employee{id=103, name='剑姬', age=31, salary=4399.02}
 Employee{id=104, name='刀妹', age=25, salary=7777.02}
 Employee{id=105, name='提莫', age=44, salary=100.02}
 

 

limit()：按个数进行取出 

employeeList
.stream()
.limit(2)
.forEach(System.out::println);
 

取出前两个结果
 

 
 
-------------选择前几个输出------------
 Employee{id=101, name='杰斯', age=29, salary=10000.02}
 Employee{id=101, name='杰斯', age=29, salary=20000.02}
 

 

distinct()：去重 

employeeList
.stream()
.distinct()
.forEach(System.out::println);
 

 

skip()：跳过前N个流，开始截取 

 employeeList
.stream()
.skip(4)
.forEach(System.out::println);
 

跳过前4个流
 

 
 
--------------跳过前4个流，取后面的流-----------
 Employee{id=104, name='刀妹', age=25, salary=7777.02}
 Employee{id=105, name='提莫', age=44, salary=100.02}
 

 

map()：对集合元素逐个进行函数操作，映射成全新的一个集合 

employeeList
.stream()
.map(x->x.getSalary()+10000) //将工资都加10000
.forEach(System.out::println);
 

 
 
------------map(接受lambda，将一个函数作为参数，应用到每个元素上，输出新的流)---------
 20000.02
 30000.02
 10500.02
 14399.02
 17777.02
 10100.02
 

 

flatmap()：接收一个函数作为参数，将流中的值进行函数操作后，然后把所有流连接成一个流 

        System.out.println("--------------flatmap(连接)-----------");
        List list = Arrays.asList("hello", "word");
        System.out.println(list);        //[hello, word]

        List collect1 = list
        .stream()
        .map(x -> x.split(""))
        .flatMap(Arrays::stream)
        .collect(Collectors.toList());

        System.out.println(collect1);    //[h, e, l, l, o, w, o, r, d] 

 
 
如果不加flatmap，会输出[ [h,e,l,l,o] [w,o,r,d] ] 两个流，flatmap就是将这两个数组流合并成了一个流
 

 

sorted()：排序，可自定义排序 

                 employeeList.stream()
                .sorted(
                        (x,y) ->{
                            if (x.getAge().equals(y.getAge())) {
                                return x.getSalary().compareTo(y.getSalary());
                            }else {
                                return x.getAge().compareTo(y.getAge());
                            }
                        }
                )
                .forEach(System.out::println);
 

 
 
--------------排序（自定义排序）-----------
 Employee{id=102, name='莫甘娜', age=19, salary=500.02}
 Employee{id=104, name='刀妹', age=25, salary=7777.02}
 Employee{id=101, name='杰斯', age=29, salary=10000.02}
 Employee{id=101, name='杰斯', age=29, salary=20000.02}
 Employee{id=103, name='剑姬', age=31, salary=4399.02}
 Employee{id=105, name='提莫', age=44, salary=100.02}
 
 
先按年龄排队，再按工资排队
 

 

Collectors.groupingBy:按条件进行分组 

Map> collect1 = employeeList
.stream()
.collect(Collectors.groupingBy(x -> x.getAge() > 20));
 

 
 
{false=[Employee{id=102, name='莫甘娜', age=19, salary=500.02}],
 
 
true=[Employee{id=101, name='杰斯', age=29, salary=10000.02},
 
 
Employee{id=101, name='杰斯', age=29, salary=20000.02},
 
 
Employee{id=103, name='剑姬', age=31, salary=4399.02},
 
 
Employee{id=104, name='刀妹', age=25, salary=7777.02},
 
 
Employee{id=105, name='提莫', age=44, salary=100.02}]}
 

 

查找匹配 

        employeeList.stream().anyMatch(x->x.getAge()==29);
        employeeList.stream().allMatch(x->x.getAge()==29);
        employeeList.stream().noneMatch(x->x.getAge()==29);
        employeeList.stream().findFirst();
        employeeList.stream().findAny();
        employeeList.stream().count();
        employeeList.stream().max((x, y) -> x.getAge().compareTo(y.getAge()));
        employeeList.stream().min(Comparator.comparing(Employee::getAge));
 

reduce()：将流中的数据反复结合起来得到一个值 

        //设置初始值
        List list = Arrays.asList(1, 2, 3);
        System.out.println(list.stream().reduce(100, (x, y) -> x * y));
        //不设置初始值
        List list = Arrays.asList(2, 2, 3);
        System.out.println(list.stream().reduce( (x, y) -> x * y));
 

 
 
600
 
 
12
 

 



终止操作 

 
 
会中止流操作，返回结果的函数
 

 


 查找与匹配 

allMatch(Predicate p) 检查是否匹配所有元素
anyMatch(Predicate )检查是否至少匹配一个元素
noneMatch(Predicate p)  检查是否没有匹配所有元素
findFirst()返回第一个元素
findAny()返回当前流中的任意元素
count() 返回流中元素总数
max(Comparator c)返回流中最大值
min(Comparator c)  返回流中最小值
forEach(Consumer c) stream API 使用内部迭代



 归约 

reduce ()将流中元素反复结合起来，得到一个值。


Collector 接口中方法 

 
 

 Collector 接口中方法的实现决定了如何对流执行收集操作(如收集到 List、Set、Map)。但是 Collectors 实用类提供了很多静态方法，可以方便地创建常见收集器实例.
 

 

 

 








转载请注明：文章转载自 www.mshxw.com















Java相关栏目本月热门文章












热门相关搜索






路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名















学习工具


代数计算器


三角函数


解析几何


立体几何






知识解答


教育知识


百科知识


生活知识


常识知识






写作必备


作文大全


作文素材


句子大全



实用范文






关于我们


关于我们


联系我们


网站地图






 交流群

名师互学网交流群




名师互学网客服

名师互学网客服












名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 








我们一直用心在做

关于我们
文章归档
网站地图
联系我们

版权所有 (c)2021-2022 MSHXW.COM


ICP备案号：晋ICP备2021003244-6号