栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java8 Stream中findAny和findFirst的区别

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java8 Stream中findAny和findFirst的区别

前言:java 8在使用流时候会用到findAny() 与findFirst() 方法使用,下面就对这两个方法使用结合源码做下区分。

首先我们来看下源码:
这两个方法都是在接口Stream类中:

1 .findFirst() 方法根据命名可以大致知道是获取Optional流中的第一个元素。
2 .findAny() 方法是获取Optional 流中任意一个,存在随机性,其实里面也是获取元素中的第一个。

具体实现方法是类似的,看下源码ReferencePipeline:

    @Override
    public final Optional findFirst() {
        return evaluate(FindOps.makeRef(true));
    }

    @Override
    public final Optional findAny() {
        return evaluate(FindOps.makeRef(false));
    }
final  R evaluate(TerminalOp terminalOp) {
        assert getOutputShape() == terminalOp.inputShape();
        if (linkedOrConsumed)
            throw new IllegalStateException(MSG_STREAM_LINKED);
        linkedOrConsumed = true;

        return isParallel()
               ? terminalOp.evaluateParallel(this, sourceSpliterator(terminalOp.getOpFlags()))
               : terminalOp.evaluateSequential(this, sourceSpliterator(terminalOp.getOpFlags()));
    }

具体逻辑我们看下evaluate 方法:
1.evaluate 方法isParallel() 会去判断是否管道是否是并行或者单独,可以理解为(同步管道或者是异步管道处理流),如果是同步处理则boolean mustFindFirst 设置无效,下面列子会做介绍
2.我们来看下terminalOp.getOpFlags() 方法默认都是获取元组中的第一个元素,下标值 0 ,小伙伴可以直接点击进去看下源码: default int getOpFlags() { return 0; }
具体感兴趣的小伙伴可以看下sourceSpliterator() 方法,介绍了元组之间的切割合并流程操作逻辑,文章这里就不做更详细介绍

最后,我们来看下列子:

   List lst1 = Arrays.asList("Jhonny", "David", "Jack", "Duke", "Jill","Dany","Julia","Jenish","Divya");
        List lst2 = Arrays.asList("Jhonny", "David", "Jack", "Duke", "Jill","Dany","Julia","Jenish","Divya");

        Optional findFirst = lst1.parallelStream().filter(x -> x.startsWith("D")).findFirst();
        Optional fidnAny = lst2.parallelStream().filter(x -> x.startsWith("J")).findAny();

        System.out.println(findFirst.get()); //总是打印出David
        System.out.println(fidnAny.get()); //会随机地打印出Jack/Jill/Julia
        for (int i = 0; i < 20; i++) {
            Optional fidnAny1 = lst2.stream().filter(x -> x.startsWith("J")).findAny();
            System.out.println(fidnAny1.get()); //这里使用stream()流对于findAny()则不生效

        }

输出结果:

David
Jill
======findany 失效场景====
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
Jhonny
 

Process finished with exit code 0

结论:通过上面方法大家在使用findAny() 方法时候需要注意是否是使用异步流处理方式,如果不是findAny() 等于findFirst(),
两者都是输出元组中最第一元素。区别在于异步流处理无法控制list顺序与 stream流放入元组中的元素顺序一致,输出结果自然也存在随机性

欢迎!大家留言提出不同意见,共同学习成长,一个正在努力成长的菜鸟…

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/918490.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号