Java8-Stream流处理

Java8中的Stream是对与集合对象有所加强的新特性,专注于集合对象进行各种非常便利,高效的聚合操作,同时提供串行与并行两种模式的汇聚操作,使用了fork/join并行方式来拆分任务、加速处理过程。注意,这里的stream与原先的文件I/O流没有必然关系,是在Java8中的新内容。

Stream有时类似于一个迭代器,但是相比原来的Iterator串行命令式的执行过程,stream通过并行方式去便利,遍历时stream数据会被分成多段,其中每一段都在不同的线程中进行处理,然后归并统一。

生成Stream的方式

  • 从Collection集合获取
list.stream()
  • 从BufferedReader获取
 java.io.BufferedReader.lines()
  • 静态工厂、自己构建

流的几种操作类型

  1. Intermediate 中间件式
    一个流的后面可以跟多个中间件式的操作,其目的主要是打开流,做出某种程度的数据映射、过滤,然后返回一个新流,交给下一步操作。
List<Integer> numbers = Arrays.asList(1,2,3,4,5,6,7,8,9);
System.out.println(
                numbers.stream()              //获取流
                        .filter(n -> n%2==0)  //Intermediate操作
                        .findFirst()); //Terminal操作
  1. Terminal 终点式
    一个流只能有一个终点式操作,当这个操作执行后,就表示流被用光了,无法再次进行其他的操作。终点式操作的执行,才会真正开始流的遍历操作,并生成一个side effect。

  2. short-circuiting 短路式
    这个操作类型与上两个并存,主要表示以下两种模式:
    对于一个中间件式操作,若接受一个无限大的stream,则返回一个有限的;
    对于一个终点式操作,若他接受一个无限大的stream,能在有限时间内计算出结果;

常用的构造流的方式

Stream stream = Stream.of("a","b","c");
stream = Arrays.stream(strArray);
stream = list.stream();

已提供的包装类型流

  • IntStream
  • LongStream
  • DoubleStream

可帮助在使用过程中减少装箱/拆箱的消耗

流的操作

1. map/flatmap

把inputStream的每个元素,映射成outputStream的另一个元素

2. filter

对原Stream的元素进行测试,通过的保存下来继续向下流

3. forEach

接受第一个lambda表达式为流中的每个元素去执行

4. reduce

把Stream的元素组合起来,它有提供一个初始值,然后依照运算规则,与前面的Stream的第一个,第二个...第n个元素进行组合

5. limit/skip

limit返回流的前n个元素,skip为扔掉流的前n个元素

6. sorted

排序

7. min/max/distinct

返回流的最小值/最大值/平均值

8. Match

allMatch:判断流中全部元素是否符合传入的predicate,符合返回true
anyMatch:判断流中有无元素是否符合传入的predicate,符合返回true
noneMatch:判断流中全部元素是否符合传入的predicate,不符合返回true

在实现上,match相关方法不需要遍历全部元素,只要有一个元素不满足断言就退出,skip余下的元素

用Collectors来进行集合的reduction操作

主要作用就是降低集合与流之间的简化、转化等操作的复杂度,实用性大,例如:

list.collect(Collectors.toList());

collect作为一个Terminal方法一般放在最后。

    原文作者:Juses_331
    原文地址: https://blog.csdn.net/No_Endless/article/details/76424502
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞