开发环境
- eclipse 4.7.3a
- jdk 10
前置知识点
关于Stream
Tips: Oracle官方称之为 “聚合操作”(Aggregate Operations)和 “管道”(Pipelines)
通常我使用集合并不是简单的把对象存储到集合中,而是使用集合来检索或统计其中特定的条目。而Jdk1.8之前的Java 集合 API 中,缺少这样类型的方法,更多的时候是使用for-each或迭代(Iterator ),完成相关的聚合操作逻辑,如sum , count , min, max 这样的操作。
面包总会有的,牛奶也会有的,我们有幸等来了Java 8。Java 8 提供了 java.util.stream 接口,它支持函数式编程(Lambda表达式), 同时它提供串行和并行两种模式进行聚合操作。
管道操作
下面的例子我们演示使用聚合API来完成如下操作
- 找出集合中的所有男性并输出他们的名字
- 计算集合中男性的平均年龄
找出集合中的所有男性并输出他们的名字
Java 8 之前
for (Person p : roster)
{
if (p.getGender() == Person.Sex.MALE)
{
System.out.println(p.getName());
}
}
使用聚合API
roster
.stream()
.filter(e -> e.getGender() == Person.Sex.MALE)
.forEach(e -> System.out.println(e.getName()));
可以看到使用stream方法通过分别调用filter(e -> e.getGender() == Person.Sex.MALE)
和forEach(e -> System.out.println(e.getName()))
替换了原有的方式。
在继续下一个例子之前,我们有必要了解一下Stream的一些概念。Stream 由一系列元素组成,它和集合不一样的地方是,它不是存储数据元素的数据结构。相反,它通过管道从数据源获取数据。
管道的概念
Tips: 使用Stream 操作集合的方式,Oracle把它称之为管道(Pipelines),我们知道管道通常在Java的IO流中出现,也就是说Stream并不是在操作集合,而是操作集合的数据流。
- 数据源:在这里它范指集合。
- 零个或多个中间操作:这里的中间操作类似于上面例子中的filter方法或者其它产生一个新的Stream对象的方法。
- 一个终止操作:指产生一个非Stream对象的结果来结束本次操作,比如上面例子中的forEach方法。
计算集合中男性的平均年龄
Java 8 之前
int count = 0;
int total = 0;
for (Person p : roster)
{
if (p.getGender() == Person.Sex.MALE)
{
System.out.println(p.getName());
total += p.getAge();
count ++;
}
}
double avg = (count == 0 ? 0 : total/count);
使用聚合API
double average = roster
.stream()
.filter(p -> p.getGender() == Person.Sex.MALE)
.mapToInt(Person::getAge)
.average()
.getAsDouble();
Tips: 考考你,在上面例子中哪些方法是中间操作,哪些是最终操作,知道的大佬欢迎在下方留言。
Stream和迭代的区别
- 聚合API使用内部迭代:它通常不包含显示的迭代方法,如iterator.next(),使用内部委托的方式确定它迭代的集合。
- 集合元素来自Stream :聚合操作处理Stream 中的元素,而不是来自集合。
- 支持函数式编程