引言
Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据。
Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象。
Stream API可以极大提高Java程序员的生产力,让程序员写出高效率、干净、简洁的代码。
这种风格将要处理的元素集合看作一种流, 流在管道中传输, 并且可以在管道的节点上进行处理, 比如筛选, 排序,聚合等。
元素流在管道中经过中间操作(intermediate operation)的处理,最后由最终操作(terminal operation)得到前面处理的结果。
1 | +--------------------+ +------+ +------+ +---+ +-------+ |
什么是Stream?
Stream(流) 是一个来自数据源的元素队列并支持聚合操作
- 元素是特定类型对象,形成一个队列。java中的Stream并不会存储元素,而是按需计算。
- 数据由于 流的来源。可以是集合,数组,I/O channel , 产生器generator等。
- 聚合操作 类似SQL语句一样操作,比如filter,map.reduce.find,match,sorted等。
和以前的Collection操作不同,Stream操作还有两个基础特征: - Pipelinling:中间操作都会返回流对象本身。这样多个操作可以串联成一个管道,如同流式风格(fluent style)。这样做可以对操作进行优化,比如延迟执行(laziness)和短路(short-circuiting)。
- 内部迭代:以前对集合遍历读书通过iterator或者for-each的方式,显式的在集合外部进行迭代,这叫做外部迭代。Stream提供了内部迭代方式,通过访问者模式(Visitor)实现。
生成流
有两种生成流的方法:
stream()-为集合创建串行流。
parallelStream()-为集合创建并行流。
1 | List<String> list=Arrays.asList("a","b","c","d","e","f","g"); |
运行输出结果为:
1 | 串行流:abcdefg |
我们发现,使用parallelStream后,结果并不按照集合原有顺序输出。为了进一步证明该操作是并行的,我们打印出线程信息。
1 | stream2.forEach(str-> System.out.println(Thread.currentThread().getName()+"->"+str)); |
运行输出结果为:
1 | main->e |
通过例子可以确信parallelStream是利用多线程进行的,这可以很大程度简化我们使用并发操作。
forEach
Stream 提供了新的方法forEach来迭代流中的每个数据。
1 | //使用foreach输出10个随机数 |
map
map 方法用于映射每个元素到对于的结果。
1 | //map代码片段 |
filter
filter方法用于通过设置的条件过滤出元素。
1 | List<Integer> muns=Arrays.asList(1,2,3,4,5,6,7,8,9); |
limit
limit 方法用于获取指定数量的流
1 | List<Integer> muns=Arrays.asList(1,2,3,4,5,6,7,8,9); |
sorted
sorted 方法用于对流进行自然排序。
1 | List<Integer> muns2=Arrays.asList(1,3,5,4,10,6,2,8,7); |
也可以对集合中对象某个属性进行排序:
1 | //创建实体,并且给年龄赋值 |
Collectors
Collectors 类实现了很多归约操作,例如将流转换成集合和聚合元素。Collectors可用于返回列表或字符串:
1 | List<String> list3=Arrays.asList("now","store","list","","e","f","g"); |
统计
一些产生统计结果的收集器也非常有用。它们主要用于int、double、long等基本类型上,它们可以用来产生类似如下的统计结果。
1 | List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5); |
Stream 完整实例
1 | package com.adanblog.demo; |