有了Lamdba表达式 , Java就具有了进行函数式编程的条件
但是作为彻底的面向对象语言 , 并不支持函数的独立存在
所以JDK1.8添加了Stream以及一些相关的接口
Stream的特点可以概括如下
- Stream是元素的序列 , 看起来有点类似Iterator
- 可以支持顺序和并行聚合的操作
可以把Stream看成一个高级版本的Iterator
Iterator只能逐个对元素进行遍历 , 然后执行某些操作
对于Stream , 只需要给出对元素进行处理的回调函数
就可以对这个元素序列进行一些操作
可以参考underscore对数组或者对象进行处理的一些方法
编程方式上十分类似
List<Integer> nums = Lists.newArrayList(5,2,1,0,null,56);
Stream<Integer> stream = nums.stream();
//过滤掉序列中的null值 并获得剩余元素的数量
long count = stream.filter(num -> num!=null).count();
System.out.println(count);//5
Lists是Guava当中的一个工具类 , 这里用它来产生一个List对象
Stream当中的很多非聚合方法 , 都是返回Stream对象 , 可以进行连缀
但是注意 : 每次调用后的结果 , 都是产生一个新的Stream对象 , 而不再是原Stream对象
此时如果再对原对象进行任何操作 , 都会抛出异常
创建Stream
有两种方式可以创建一个Stream对象
- 通过Stream接口当中的静态工厂方法
- 通过Collection接口的默认方法stream() , 上面的例子用的就是这种方式
Stream接口中的静态工厂方法
of方法- 有两个重载形式 , 一个是接收单一值 , 一个是接收多个值
Stream<Integer> intStream = Stream.of(10,20,30);
Stream<String> strStream = Stream.of("test");
generate方法- 获得一个生成器
这个方法产生的Stream是一个惰性序列 , 也就是它并不保存这个序列中所有的内容 , 每次需要获取的时候 , 再去生成
通过这种方式 , 可以节约大量的内存 , 也可以获得一个无限长的序列
Stream<Integer> randomNums = Stream.generate(()->(int)(Math.random()*1000));
randomNums.limit(20).forEach(System.out::println);
常用的非聚合操作
- distinct - 去除序列中的重复元素 ( 依赖元素的equals方法 )
- filter - 对于实参函数执行结果为false的 , 从序列中去除
- map - 对于元素逐个使用实参函数进行处理 , 并将返回值组装成一个新的序列
- peek - 克隆原Stream产生一个新的Stream , 并提供一个消费函数 , 当新Stream中的每个元素被消费的时候都会调用该函数
- limit - 截取前若干个元素
- skip - 丢弃前若干个元素
- sorted - 对序列中的元素进行排序 ( 可以指定Comparator )
常用的聚合操作
聚合操作（也称为折叠）接受一个元素序列为输入，反复使用某个合并操作，把序列中的元素合并成一个汇总的结果。
- collect - 将所有的元素放入到一个Collection容器当中 ( 属于可变聚合 )
- reduce - 将前两个元素使用指定函数进行聚合 , 将结果与第三个元素进行聚合 , 依次进行下去
- count - 获得序列中元素的数量
Stream当中的方法大部分都可以根据名称猜出意思
就不一一介绍了 , 详细内容参阅JDK源码