详解Java 8中Stream类型的“懒”操作

详解Java 8中Stream类型的“懒”操作

编程文章jaq1232025-05-02 17:43:5314A+A-

在进入正题之前,我们需要先引入Java 8中Stream类型的两个很重要的操作:

中间和终结操作(Intermediate and Terminal Operation)

Stream类型有两种类型的方法:

  • 中间操作(Intermediate Operation)
  • 终结操作(Terminal Operation)

Stream之所以“懒”的秘密也在于每次在使用Stream时,都会连接多个中间操作,并在最后附上一个结束操作。 像map和filter这样的方法是中间操作,在调用它们时,会立即返回另一个Stream对象。而对于reduce及findFirst这样的方法,它们是终结操作,在调用它们时才会执行真正的操作来获取需要的值。

从一个例子出发:

比如,当我们需要打印出第一个长度为3的大写名字时:

public class LazyStreams {
    private static int length(final String name) {
        System.out.println("getting length for " + name);
        return name.length;
    }
    private static String toUpper(final String name ) {
        System.out.println("converting to uppercase: " + name);
        return name.toUpperCase;
    }
    public static void main(final String[] args) {
        List<String> names = Arrays.asList("Brad", "Kate", "Kim", "Jack", "Joe", "Mike", "Susan", "George", "Robert", "Julia", "Parker", "Benson");

        final String firstNameWith3Letters = names.stream
 .filter(name -> length(name) == 3)
 .map(name -> toUpper(name))
 .findFirst
 .get;

        System.out.println(firstNameWith3Letters);
    }
}

你可能认为以上的代码会对names集合进行很多操作,比如首先遍历一次集合得到长度为3的所有名字,再遍历一次filter得到的集合,将名字转换为大写。最后再从大写名字的集合中找到第一个并返回。这也是经典情况下Java Eager处理的角度。此时的处理顺序是这样的

对于Stream操作,更好的代码阅读顺序是从右到左,或者从下到上。每一个操作都只会做到恰到好处。如果以Eager的视角来阅读上述代码,它也许会执行15步操作:

可是实际情况并不是这样,不要忘了Stream可是非常“懒”的,它不会执行任何多余的操作。实际上,只有当findFirst方法被调用时,filter和map方法才会被真正触发。而filter也不会一口气对整个集合实现过滤,它会一个个的过滤,如果发现了符合条件的元素,会将该元素置入到下一个中间操作,也就是map方法中。所以实际的情况是这样的:

\

控制台的输出是这样的:

getting length for Brad
getting length for Kate
getting length for Kim
converting to uppercase: Kim
KIM

为了更好理解上述过程,我们将Lambda表达式换为经典的Java写法,即匿名内部类的形式:

final String firstNameWith3Letters = names.stream
 .filter(new Predicate<String>{
 public boolean test(String name){
 return length(name)==3;
 }
 })
 .map(new Function<String,String>{
 public String apply(String name){
 return toUpper(name);
 }
 })
 .findFirst
 .get;  

执行的见下图:

很容易得出之前的结论:只有当findFirst方法被调用时,filter和map方法才会被真正触发。而filter也不会一口气对整个集合实现过滤,它会一个个的过滤,如果发现了符合条件的元素,会将该元素置入到下一个中间操作,也就是map方法中。

当终结操作获得了它需要的答案时,整个计算过程就结束了。如果没有获得到答案,那么它会要求中间操作对更多的集合元素进行计算,直到找到答案或者整个集合被处理完毕。

JDK会将所有的中间操作合并成一个,这个过程被称为熔断操作(Fusing Operation)。因此,在最坏的情况下(即集合中没有符合要求的元素),集合也只会被遍历一次,而不会像我们想象的那样执行了多次遍历。

为了看清楚在底层发生的事情,我们可以将以上对Stream的操作按照类型进行分割:

Stream<String> namesWith3Letters = names.stream
    .filter(name -> length(name) == 3)
    .map(name -> toUpper(name));

System.out.println("Stream created, filtered, mapped...");
System.out.println("ready to call findFirst...");

final String firstNameWith3Letters = namesWith3Letters.findFirst.get;

System.out.println(firstNameWith3Letters);
// 输出结果
// Stream created, filtered, mapped...
// ready to call findFirst...
// getting length for Brad
// getting length for Kate
// getting length for Kim
// converting to uppercase: Kim
// KIM

根据输出的结果,我们可以发现在声明了Strema对象上的中间操作之后,中间操作并没有被执行。只有当真正发生了findFirst调用之后,才会执行中间操作。

参考资料:

撸主比较懒,上文中的例子和前两张图来自于 CSDN 博主 dm_vincent 的博客《 [Java 8] (7) 利用Stream类型的"懒"操作 》

点击这里复制本文地址 以上内容由jaq123整理呈现,请务必在转载分享时注明本文地址!如对内容有疑问,请联系我们,谢谢!

苍茫编程网 © All Rights Reserved.  蜀ICP备2024111239号-21