Java 8 自定义流Collector实现
Java 8 自定义流Collector实现
前文我们看到 Java 8 Collectors提供了很多内置实现。但有时我们需要实现一些特定功能满足业务需要,本文带你学习如何自定义Collector的实现,计算字符串流中所有单词的长度。
需求说明
假设有字符串流,利用每个字符串对象有方法length()————计算并返回单词长度。我们想创建自定义Collector,实现reduce操作,计算流中所有单词的长度之和。
使用 Collector.of() 方法
为了创建自定义Collector,需要实现Collector接口。现在,我们不使用传统方法,而是使用Collector.of()静态方法创建自定义Collector。
不仅是为了更精简和增强可读性,还因为这种方法可以忽略部分不必要的实现。实际上,Collector接口仅需要三个必须部分————提供者(supplier), 累加器(accumulator) 以及合并器(combiner)。
结果容器提供者(supplier)
实现Collector,必须提供结果容器,即累加值存储的地方。下面代码提供了结果容器:
() -> new int[1]
你可能会想,为什么是 new int[1],而不是int变量作为初始化值。原因是Collector接口需要结果容器能够以可变的方式进行更新。
累加元素(accumulator)
接下来,我们需要创建函数实现增加元素至结果容器。在我们的示例中,即单词的长度增加至结果容器:
(result, item) -> result[0] += item.length()
该函数是Consumer类型,其不返回任何值,仅以可变的方式更新结果容器————即数组中的第一个元素。
合并器(combiner)
在reduction序列操作中,提供者(supplier) 和 累加器(accumulator) 已经足够了,但为了能够实现并行操作,我们需要实现一个合并器。合并器(combiner)是定义两个结果如何合并的函数。
在并行环境下,流被分为多个部分,每个部分被并行累加。当所有部分都完成时,结果需要使用合并器函数进行合并。下面请看我们的实现代码:
(result1, result2) -> {result1[0] += result2[0];return result1;
}
最小的自定义Collector
现在我们已经所有必要组件,整合在一起就是我们的Collector:
wordStream.collect(Collector.of(()-> new int[1],(result, item) -> result[0] += item.length(),(result1, result2) -> {result1[0] += result2[0];return result1;}
));
上面方案有个小问题,其直接返回结果容器即int[]类型。实际我们需要的字符串长度,不是结果容器。
最后一个转换
我们可以很容易实现,增加一个函数,其映射结果容器至我们需要的类型。这里我们仅仅需要数组的第一个元素:
total -> total[0]
最后完整代码为:
private List<String> wordList = Arrays.asList("tommy", "is", "a", "java", "developer");@Testpublic void wordCountTest() {Stream<String> wordStream = wordList.stream();int wordCnt = wordStream.collect(Collector.of(()-> new int[1],(result, item) -> result[0] += item.length(),(result1, result2) -> {result1[0] += result2[0];return result1;},total -> total[0]));System.out.println("wordCnt = " + wordCnt);}
如果把我们自定义的Collector赋值给变量,则代码可以简化为:
int wordCount = wordStream.collect(totalWordCountCollector);
优化参数
最后,我们看下优化参数。即自定义Collector支持不同类型的优化参数。
使用Collector.of()
可以在参数最后增加 Characteristics 作为可变参数:
Collector.of( // supplier,// accumulator,// combiner,// finisher, Collector.Characteristics.CONCURRENT,Collector.Characteristics.IDENTITY_FINISH,// ...
);
有三种 Characteristics 可以使用:
- CONCURRENT — 指明结果容器可以被多个并发累加器使用
- IDENTITY_FINISH — 指明结束函数是恒等函数且可以被忽略
- UNORDERED — 指明collector不依赖元素顺序
总结
本文我们学习了如何自定义Java 8 自定义 流的 Collector实现.更多内容可以参考官方文档。
Java 8 自定义流Collector实现相关推荐
- 怎么在java中创建一个自定义的collector
文章目录 简介 Collector介绍 自定义Collector 总结 怎么在java中创建一个自定义的collector 简介 在之前的java collectors文章里面,我们讲到了stream ...
- java全局变量怎么定义_怎么在java中创建一个自定义的collector
简介 在之前的java collectors文章里面,我们讲到了stream的collect方法可以调用Collectors里面的toList()或者toMap()方法,将结果转换为特定的集合类. 今 ...
- c++中的new_怎么在java中创建一个自定义的collector
简介 在之前的java collectors文章里面,我们讲到了stream的collect方法可以调用Collectors里面的toList()或者toMap()方法,将结果转换为特定的集合类. 今 ...
- java中collector使用_怎么在java中创建一个自定义的collector
怎么在java中创建一个自定义的collector 简介 在之前的java collectors文章里面,我们讲到了stream的collect方法可以调用Collectors里面的toList()或 ...
- 【Java 8】流(Stream API)
本文参考书籍<Java 8实战>,陆明刚.劳佳 译,如有侵权,请联系删除! 在本章中,我们会使用这样一个例子:一个menu,它是一张菜肴列表: List<Dish> menu ...
- Java基础—IO流
第一讲 IO概述 1. 流的概念 IO流即InputOutput的缩写,在Java中IO流用来处理设备之间的数据传输,Java对数据的操作是通过IO流的方式, 我们可以把IO流抽象的当作一根管道, ...
- Java IO: 字符流的Buffered和Filter
作者: Jakob Jenkov 译者: 李璟(jlee381344197@gmail.com) 本章节将简要介绍缓冲与过滤相关的reader和writer,主要涉及BufferedReader.B ...
- 三万字的java I/O流基础总结看完肯定能把女朋友教会
目录: 1.File类详解 2.I/O流概述 3.字节输出流(OutputStream) 4.字节输入流(InputStream) 5. 字符流概述 6.字符输入流(Reader) 7.字符输出流(W ...
- Java 8 Stream 流用法及语法
Java 8 Stream 流用法 1.简介 Stream流 最全的用法 Stream 能用来干什么?用来处理集合,通过 使用Stream API 对集合数据进行操作,就类似于使用 SQL 执行的数据 ...
最新文章
- 属性与内存管理(属性与内存管理都是相互关联的)
- js中this关键字的使用
- Xmemcached学习笔记一(安装memcached)
- 使用idea创建JavaWeb项目
- mysql 增加bit列_mysql – 如何对BIT(…)数据类型列使用substr(…)?
- Java程序员必备:常见OOM异常分析
- pojo和java对象_java对象 POJO和JavaBean的区别
- Linux多进程编程之在线词典
- jsoup教程_2 http-client 讲解
- vue中修改了数据但视图无法更新的情况
- 获取编译学习笔记 (十一年)—— 内的中间
- linux python测试程序,linux下测试python程序执行时间
- 微信小程序-tab切换(scroll-view + swiper)
- oracle 新增字段
- 关于grldr is missing
- 高通8953启动流程
- P2150 [NOI2015]寿司晚宴
- Android网易评论盖楼效果实现
- 关于报错django.core.exceptions.ImproperlyConfigured: mysqlclient 1.3.13 or newer is required; you hav
- Python3 面向对象编程