java中stream的peek()用法详解

 更新时间:2024年01月19日 09:54:55   作者:CUIYD_1989  
这篇文章主要介绍了java中stream的peek()用法详解,peek的作用是
改变元素的内部状态,对每个object执行 saveInfomation(object, params),然后把结果收集到一个 List 里,这里涉及到了最终操作,需要的朋友可以参考下

前言

最近看到一段代码:

aeFormList.stream().peek(object -> saveInfomation(object, params)).collect(Collectors.toList());

之前没有用过peek,于是查了一下,peek的作用是:

改变元素的内部状态

从这句话中可以看出,上面代码的意思是:对每个object执行 saveInfomation(object, params),然后把结果收集到一个 List 里。 这里涉及到了最终操作。

最终操作(terminal operation)

peek() 并不是一个最终操作(terminal operation)。stream 被设计为“元素只有在最终操作需要时才会被处理”。如果没有最终操作的“拉动”,那么 stream 中就没有操作会真正执行。

在上面的例子中,.collect(Collectors.toList())就是一个最终操作,而且这个操作会“拉动”所有元素。这样一来,每个元素都一定会被应用 peek() 方法。

但在使用 peek() 时仍然需要注意,因为它只保证作用于流经管道的元素,但并不保证全部元素都会流经管道。

peek() vs forEach()

forEach() 则是一个最终操作。除此之外,peek() 和 forEach() 再无其他不同。

那么到底什么是最终操作,我们看如下代码:

使用了forEach()之后,在结尾使用.collect方法会报错。因为forEach() 已经是一个最终操作无法再添加最终操作。

在这里插入图片描述

在使用peek()之后,可以使用.collect方法。

在这里插入图片描述

peek() 的典型用法:协助调试

正因为 peek() 不是一个最终操作,不会影响“哪些元素会流过”,所以十分适合在调试的时候,用来打印出流经管道的元素。例如:

Stream.of("one", "two", "three", "four")
         .filter(e -> e.length() > 3)
         .peek(e -> System.out.println("Filtered value: " + e))
         .map(String::toUpperCase)
         .peek(e -> System.out.println("Mapped value: " + e))
         .collect(Collectors.toList());

总结

  1. 如果想对流经的每个元素应用一个函数,从而改变某些状态,那么请用 forEach();
  2. 如果想打印流经的每个元素的状态(日志或 debug),这时应该用 peek();

到此这篇关于java中stream的peek()用法详解的文章就介绍到这了,更多相关stream的peek()内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • java 动态生成SQL的实例讲解

    java 动态生成SQL的实例讲解

    下面小编就为大家带来一篇java 动态生成SQL的实例讲解。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-07-07
  • Java使用自动化部署工具Gradle中的任务设定教程

    Java使用自动化部署工具Gradle中的任务设定教程

    Grandle使用同样运行于JVM上的Groovy语言编写,本文会对此进行初步够用的讲解,接下来我们就一起来看一下Java使用自动化部署工具Gradle中的任务设定教程:
    2016-06-06
  • 聊聊SpringCloud和SpringCloudAlibaba的区别

    聊聊SpringCloud和SpringCloudAlibaba的区别

    这篇文章主要介绍了SpringCloud和SpringCloudAlibaba的区别,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11
  • SpringBoot中MyBatis-Flex的集成和使用实现

    SpringBoot中MyBatis-Flex的集成和使用实现

    MyBatis-Flex是一个基于MyBatis的数据访问框架,MyBatis-Flex能够极大地提高我们的开发效率和开发体验,本文主要介绍了SpringBoot中MyBatis-Flex的集成和使用实现,具有一定的参考价值,感兴趣的可以了解一下
    2023-12-12
  • SpringBoot整合Netty心跳机制过程详解

    SpringBoot整合Netty心跳机制过程详解

    这篇文章主要介绍了SpringBoot整合Netty心跳机制过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • 基于java中的PO VO DAO BO POJO(详解)

    基于java中的PO VO DAO BO POJO(详解)

    下面小编就为大家带来一篇基于java中的PO VO DAO BO POJO(详解)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • Java中Dijkstra算法求解最短路径的实现

    Java中Dijkstra算法求解最短路径的实现

    Dijkstra算法是一种解决最短路径问题的常用算法,本文主要介绍了Java中Dijkstra算法求解最短路径的实现,具有一定的参考价值,感兴趣的可以了解一下
    2023-09-09
  • SpringBoot实现过滤器拦截器的耗时对比

    SpringBoot实现过滤器拦截器的耗时对比

    这篇文章主要为大家详细介绍了SpringBoot实现过滤器拦截器的输出接口耗时对比,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一下
    2022-06-06
  • Spring Cloud学习教程之Zuul统一异常处理与回退

    Spring Cloud学习教程之Zuul统一异常处理与回退

    Spring Cloud Zuul对异常的处理整体来说还是比较方便的,流程也比较清晰,下面这篇文章主要给大家介绍了关于Spring Cloud学习教程之Zuul统一异常处理与回退的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考借鉴,下面随着小编来一起学习学习吧。
    2018-04-04
  • Spring Boot 使用 Disruptor 做内部高性能消息队列

    Spring Boot 使用 Disruptor 做内部高性能消息队列

    这篇文章主要介绍了Spring Boot 使用 Disruptor 做内部高性能消息队列,工作中遇到项目使用Disruptor做消息队列,对你没看错,不是Kafka,也不是rabbitmq。Disruptor有个最大的优点就是快,还有一点它是开源的哦,下面做个简单的记录
    2022-06-06

最新评论