Java8 Stream reduce操作
Reduce,顾名思义为减少的意思,就是根据指定的计算模型将Stream中的值计算得到一个最终结果。在之前的一篇文章Java8函数式编程中简单介绍,Stream的count、min 和max方法底层都是依赖reduce实现的,本篇文章将简单介绍一下Java8 Stream reduce的几种基本用法。
首先来看一下Reduce三种形式:
S.N. 方法说明
1 Optional<T> reduce(BinaryOperator<T> accumulator);
对Stream中的数据通过累加器accumulator迭代计算,最终得到一个Optional对象
2 T reduce(T identity, BinaryOperator<T> accumulator);
给定一个初始值identity,通过累加器accumulator迭代计算,得到一个同Stream中数据同类型的结果
3 <U> U reduce(U identity, BiFunction<U, ? super T, U> accumulator, BinaryOperator<U> combiner);
给定一个初始值identity,通过累加器accumulator迭代计算,得到一个identity类型的结果,第三个参数用于使用并行 流时合并结果
1. Optional<T> reduce(BinaryOperator<T> accumulator);
首先看一下函数式接口BinaryOperator,继承于BiFunction,Bifunction中有一个apply方法,接收两个参数,返回一个结果。如下:
@FunctionalInterfacepublic interface BinaryOperator<T> extends BiFunction<T,T,T> {}@FunctionalInterfacepublic interface BiFunction<T, U, R> {R apply(T t, U u);}
也就是说,reduce(BinaryOperator<T> accumulator)方法需要一个函数式接口参数,该函数式接口需要两个参数,返回一个结果(reduce中返回的结果会作为下次累加器计算的第一个参数),也就是所讲的累加器。所以reduce(BinaryOperator<T> accumulator)方法可以如下调用:
@Testpublic void reduceTest() {Optional accResult = Stream.of(1, 2, 3, 4).reduce((acc, item) -> {System.out.println("acc : " + acc);acc += item;System.out.println("item: " + item);System.out.println("acc+ : " + acc);System.out.println("--------");return acc;});System.out.println(accResult);}
运行结果:
acc : 1item: 2acc+ : 3--------acc : 3item: 3acc+ : 6--------acc : 6item: 4acc+ : 10--------Optional[10]
2. T reduce(T identity, BinaryOperator<T> accumulator);
提供一个跟Stream中数据同类型的初始值identity,通过累加器accumulator迭代计算Stream中的数据,得到一个跟Stream中数据相同类型的最终结果,可以如下调用:
@Testpublic void reduceTest1() {int accResult = Stream.of(1, 2, 3, 4).reduce(100, (acc, item) -> {System.out.println("acc : " + acc);acc += item;System.out.println("item: " + item);System.out.println("acc+ : " + acc);System.out.println("--------");return acc;});System.out.println(accResult);}
运行结果:
acc : 100item: 1acc+ : 101--------acc : 101item: 2acc+ : 103--------acc : 103item: 3acc+ : 106--------acc : 106item: 4acc+ : 110--------110
3. <U> U reduce(U identity, BiFunction<U, ? super T, U> accumulator, BinaryOperator<U> combiner);
首先看一下BiFunction的三个泛型类型分别是U、 ? super T、U,参考BiFunction函数式接口apply方法定义可以知道,累加器累加器通过类型为U和? super T的两个输入值计算得到一个U类型的结果返回。也就是说这种reduce方法,提供一个不同于Stream中数据类型的初始值,通过累加器规则迭代计算Stream中的数据,最终得到一个同初始值同类型的结果。看一个调用示例:
@Testpublic void reduceTest2() {ArrayList<Integer> accResult_ = Stream.of(2, 3, 4).reduce(Lists.newArrayList(1),(acc, item) -> {acc.add(item);System.out.println("item: " + item);System.out.println("acc+ : " + acc);System.out.println("BiFunction");return acc;}, (acc, item) -> {System.out.println("BinaryOperator");acc.addAll(item);System.out.println("item: " + item);System.out.println("acc+ : " + acc);System.out.println("--------");return acc;});System.out.println("accResult_: " + accResult_);}
运行结果:
item: 2acc+ : [1, 2]BiFunctionitem: 3acc+ : [1, 2, 3]BiFunctionitem: 4acc+ : [1, 2, 3, 4]BiFunctionaccResult_: [1, 2, 3, 4]
通过运行结果可以看出,第三个参数定义的规则并没有执行。这是因为reduce的第三个参数是在使用parallelStream的reduce操作时,合并各个流结果的,本例中使用的是stream,所以第三个参数是不起作用的。上述示例,提供一个只有一个元素1的arrayList,通过累加器迭代,将stream中的数据添加到arrayList中。
以上就是stream中reduce的三种用法,用来通过特定的规则计算stream中的值,得到一个最终结果,其实还是很简单的。推荐一篇刚看到的讲解Java8 Stream的文章,Java Stream 详解,我陆陆续续也写了好几篇关于Java8新特性的文章了,但是比较下来并没有上面那篇文写的那么体系,之后的文章可以借鉴一下那篇文章的组织方法。
参考链接:
- Java 8系列之Stream中万能的reduce
- Java8初体验(二)Stream语法详解
Java8 Stream reduce操作相关推荐
- java8 stream reduce 方法用法 java stream reduce 方法使用方法
java8 stream reduce 方法用法 java stream reduce 方法使用方法 一.背景 在使用Stream的reduce方法时,发现该方法有 3个重载方法,分别是: 一个参数. ...
- Java8 Stream流操作在用户系统中的妙用
在做目前这个项目的时候,发现以前有一个筛选的需求,老程序员是这么做的,先请求Http服务器得到一长串json数据,大概用A4纸打了40多页那么多,然后将这些对象写入到sqlite数据库中,再用数据库查 ...
- Java基础学习总结(132)——Java8 Stream流操作学习总结
传统的数据处理都是用循环来解决,而不是像搜索数据库那样有具体的搜索语句,而Java8的Stream提供了很好的方案,往往一行就搞定了,而且Stream还可以链式操作,一行代码实现多个循环的功能,代码风 ...
- java8 stream流操作集合交集,差集,并集,过滤,分组,去重,排序,聚合等
测试对象 public class Person {private String name;private Integer age;private Integer weight;public Pers ...
- Java8——Stream流操作List排序_List集合中每个对象元素按时间顺序排序
一个学生类的实体类 @Data public class Student {private Long id;private String name;private int age;private Do ...
- java8 steam常用操作
java8 stream常用操作 遍历 list.stream().forEach(System.out::println); 获取实体list某个字段集合 list.stream().map(e - ...
- java8 Stream流【华为3面】
华为三面@java8 stream流操作面试题 前言:华为三面考了个很简单的基础编程,就是java8 Stream流操作,太久没写,也是没掌握好java基础直接搞得措手不及,stream两行代码的事情 ...
- JAVA8 Stream方法使用详解reduce、IntStream(二)
文章目录 一 归约 1.元素求和 2.最大值和最小值 二.数值流 1.映射数值流 2.转换对象流 3.数值范围 三.构建流 1.由值创建流 2.由数组创建流 3.由文件生成流 4.由函数生成流 此章节 ...
- java reduce 分组_使用JAVA8 stream中三个参数的reduce方法对List进行分组统计
背景 平时在编写前端代码时,习惯使用lodash来编写'野生'的JavaScript; lodash提供来一套完整的API对JS对象(Array,Object,Collection等)进行操作,这其中 ...
最新文章
- FPGA基础知识极简教程(6)UART通信与移位寄存器的应用
- 让CoreData更简单些
- 【C 语言】二级指针作为输入 ( 指针数组 | 复杂指针解读 )
- SQL Server 数据库的整理优化的基本过程(二)
- 随身风暴英雄接入云信,玩家即时通讯轻松搞定
- 数据科学竞赛-文本分类
- 使用python学线性代数_二项式过程| 使用Python的线性代数
- MySQL 大表优化方案,收藏了细看!
- (干货!)Tomcat性能优化
- (47)Verilog HDL UART接收设计
- 解决下载GitHub项目速度慢的问题(2019.1.21亲测有效)
- python编程入门-编程零基础应当如何开始学习 Python?
- Spring整合MyBatis之SqlSession对象的产生
- 【C/C++】共用体(union)
- Flutter dart 某一天、某一周、某一月、某一年的时间戳和时间
- POI XWPFParagraph.getRuns分段混乱问题解决
- # 互动媒体期末作业——P5.js“画板”
- 使用MPU6050在STM32F103C8T6中的硬件I2C数据传输
- golang力扣leetcode 1823.找出游戏的获胜者
- docker+mesos+marathon
热门文章
- datax从gbase8a同步上亿大表到mysql5.7中
- python url编码与解码
- devops+备份mysql_MySQL的备份和恢复 Devops、小铁匠
- java textsharp,月光软件站 - 编程文档 - 其他语言 - 利用TextEditorControl控件现代码语法高亮显示...
- uniqueResult和list
- 努比亚5s升级鸿蒙,荣耀可升级鸿蒙,覆盖多款机型!赵明:友商“最危险”的时候!...
- 点餐微信小程序系统 毕业设计-附源码221144
- 小米用上鸿蒙系统,红米小米手机刷新了鸿蒙系统后还能用吗 红米小米手机刷鸿蒙系统图文攻略...
- 用ObjectArx进行CAD二次开发的准备工作
- Python学习——02-Python基础——【8-面向对象的程序设计】——静态、组合、继承...