Java Stream中peek和map不为人知的秘密

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 Tair(兼容Redis),内存型 2GB
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
简介: 本文通过一个Java Stream中的示例,探讨了`peek`方法在流式处理中的应用及其潜在问题。首先介绍了`peek`的基本定义与使用,并通过代码展示了其如何在流中对每个元素进行操作而不返回结果。接着讨论了`peek`作为中间操作的懒执行特性,强调了如果没有终端操作则不会执行的问题。文章指出,在某些情况下使用`peek`可能比`map`更简洁,但也需注意其懒执行带来的影响。

有段代码如下,这里我开始用Java Stream 中的map来修改对象的值

less

代码解读

复制代码

 retPage.setRecords(retList.stream().map(questionPageVO -> {
    questionPageVO.setCreateUserName(userIdAndUserMap.get(questionPageVO.getCreateId()).getUsername());
    questionPageVO.setUpdateUserName(userIdAndUserMap.get(questionPageVO.getUpdateId()).getUsername());
    return questionPageVO;
}).collect(Collectors.toList()));

但idea提示我这里可以替换为peek,

替换之后的写法

less

代码解读

复制代码

retPage.setRecords(retList.stream().peek(questionPageVO -> {
    questionPageVO.setCreateUserName(userIdAndUserMap.get(questionPageVO.getCreateId()).getUsername());
    questionPageVO.setUpdateUserName(userIdAndUserMap.get(questionPageVO.getUpdateId()).getUsername());
}).collect(Collectors.toList()));

这样确实更简单整洁了,但peek这样用真的合适吗? 今天我们就来讲一下peek的一些不为人知的缺点。

peek的基本定义和使用

  1. 先来看看peek的定义:

swift

代码解读

复制代码

Stream<T> peek(Consumer<? super T> action);

peek方法接受一个Consumer参数,返回一个Stream结果。

Consumer是一个FunctionalInterface,它需要实现的方法是下面这个:

arduino

代码解读

复制代码

void accept(T t);

accept对传入的参数T进行处理,但是并不返回任何结果。

  1. peek的基本使用

csharp

代码解读

复制代码

public static void baseUse() {
    List<Integer> list = Stream.of(1,2,3)
            .peek(System.out::println)
            .collect(Collectors.toList());
    System.out.println(list);
}

输出内容:

csharp

代码解读

复制代码

1
2
3
[1, 2, 3]

3.  peek的流式处理

csharp

代码解读

复制代码

public static void peekForEach() {
    Stream.of(1,2,3)
            .peek(System.out::println)
            .forEach(e ->  System.out.println("forEach:" + e));
}

输出内容:

makefile

代码解读

复制代码

1
forEach:1
2
forEach:2
3
forEach:3

通过输出内容也可以看出,流式处理流程,是对应流中每一个元素,分别经历peekforEach操作(即一个元素执行完所有流程),而不是等peek完所有元素元素后再执行forEach

坑一:Stream的懒执行策略

之所以有流操作,是因为有时候处理的数据比较多,无法一次性加载到内存中。

为了优化stream的链式调用效率,stream还提供了一个懒加载策略。

什么是懒加载呢?

懒加载也叫intermediate operation, 在stream的方法中,大部分都是懒加载,另外部分则是terminal operation, 例如collectcount等,当有这种非懒加载的方法调用时,整个链式都会被执行,如开始的baseUse示例。

peekmap,都是懒加载方法,即intermediate operation

intermediate operation的特点是立即返回,如果最后没有以terminal operation结束,intermediate operation实际上是不会执行的。

贴个官方解释图

让我们来看这个示例:

csharp

代码解读

复制代码

public static void peekLazy() {
    Stream.of(1,2,3)
            .peek(e -> System.out.println("peek lazy: " + e));
}

执行之后,结果什么都没输出,表示peek中的逻辑没有被调用这里就是很大的一个坑,使用的时候要注意。

同理这里map也是一样。

csharp

代码解读

复制代码

public static void mapLazy() {
    Stream.of(1,2,3)
            .map(e -> {
                e = e+1;
                System.out.println("map lazy: " + e);
                return e;
            });
}


转载来源:https://juejin.cn/post/7394376050372657204

相关文章
|
22天前
|
存储 Java API
Java——Stream流详解
Stream流是JDK 8引入的概念,用于高效处理集合或数组数据。其API支持声明式编程,操作分为中间操作和终端操作。中间操作包括过滤、映射、排序等,可链式调用;终端操作则完成数据处理,如遍历、收集等。Stream流简化了集合与数组的操作,提升了代码的简洁性
42 11
Java——Stream流详解
|
1月前
|
Java API C++
Java 8 Stream Api 中的 peek 操作
本文介绍了Java中`Stream`的`peek`操作,该操作通过`Consumer&lt;T&gt;`函数消费流中的每个元素,但不改变元素类型。文章详细解释了`Consumer&lt;T&gt;`接口及其使用场景,并通过示例代码展示了`peek`操作的应用。此外,还对比了`peek`与`map`的区别,帮助读者更好地理解这两种操作的不同用途。作者为码农小胖哥,原文发布于稀土掘金。
Java 8 Stream Api 中的 peek 操作
|
22天前
|
Java 大数据 API
Java 流(Stream)、文件(File)和IO的区别
Java中的流(Stream)、文件(File)和输入/输出(I/O)是处理数据的关键概念。`File`类用于基本文件操作,如创建、删除和检查文件;流则提供了数据读写的抽象机制,适用于文件、内存和网络等多种数据源;I/O涵盖更广泛的输入输出操作,包括文件I/O、网络通信等,并支持异常处理和缓冲等功能。实际开发中,这三者常结合使用,以实现高效的数据处理。例如,`File`用于管理文件路径,`Stream`用于读写数据,I/O则处理复杂的输入输出需求。
|
17天前
|
Java 程序员 API
Java 8新特性之Lambda表达式与Stream API的探索
【9月更文挑战第24天】本文将深入浅出地介绍Java 8中的重要新特性——Lambda表达式和Stream API,通过实例解析其语法、用法及背后的设计哲学。我们将一探究竟,看看这些新特性如何让Java代码变得更加简洁、易读且富有表现力,同时提升程序的性能和开发效率。
|
16天前
|
SQL Java Linux
Java 8 API添加了一个新的抽象称为流Stream
Java 8 API添加了一个新的抽象称为流Stream
|
20天前
|
Java 大数据 API
Java8的stream里的并行度如何使用?效率有提升吗?
Java8的stream里的并行度如何使用?效率有提升吗?
16 4
|
3天前
|
存储 分布式计算 Java
Stream很好,Map很酷,但答应我别用toMap():Java开发中的高效集合操作
在Java的世界里,Stream API和Map集合无疑是两大强大的工具,它们极大地简化了数据处理和集合操作的复杂度。然而,在享受这些便利的同时,我们也应当警惕一些潜在的陷阱,尤其是当Stream与Map结合使用时。本文将深入探讨Stream与Map的优雅用法,并特别指出在使用toMap()方法时需要注意的问题,旨在帮助大家在工作中更高效、更安全地使用这些技术。
14 0
|
Java
Java8中stream流处理数据21个小案例(学习使用)
Java8中stream流处理数据21个小案例(学习使用)
91 0
|
SQL 存储 前端开发
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
138 0
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
|
Java 程序员 API
Java 8 Stream API学习总结
Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据。Stream API可以极大提高Java程序员的生产力,让程序员写出高效率、干净、简洁的代码。这种风格将要处理的元素集合看作一种流, 流在管道中传输, 并且可以在管道的节点上进行处理, 比如筛选, 排序,聚合等。
1023 0