Java Stream API的二度深入

Java Stream API的二度深入

在这里插入图片描述

前言

为什么会写这样一篇文章呢？

1.面试的时候，一位前辈对我这方面有过一次提问，我随口回答，前辈很信任我，以此文致敬前辈！

2.去回顾，去扎实，对得起前辈的信任！

3.Stream API 用起来很方便，所以很重要，所以还得学！

Stream API的三个阶段

在Java中，Stream 是Java 8引入的一个新概念，用于处理集合（Collections）数据的一种抽象。Java的Stream API 提供了一种声明式的方式来操作数据集合，可以用更简洁、可读性更强的代码来进行集合的操作。

Java Stream API的操作可以分为三个阶段：

  1. 创建流（Creation of Stream）： 这个阶段涉及到从不同的数据源创建流，可以是集合、数组、I/O通道等。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Stream<Integer> stream = numbers.stream();

  2. 中间操作（Intermediate Operations）： 这个阶段包括对流的转换操作，可以对流进行过滤、映射、排序等操作。这些操作并不会改变原始数据源，而是返回一个新的流。

    Stream<Integer> filteredStream = stream.filter(x -> x > 2);

  3. 终端操作（Terminal Operations）： 这个阶段是对流进行最终操作，触发流的遍历，可以产生一个结果或者副作用。终端操作是流的最后一个操作，执行后流将不可再用。

    long count = filteredStream.count();

这三个阶段的设计使得可以通过链式调用的方式组合多个操作，从而编写更为清晰和简洁的代码。这种方式也有助于提高代码的可读性和可维护性。

当然，这里只是对于Stream API三个阶段的概述，只是告诉大家，简单分为三个阶段，至于三个阶段里面有哪些主要的方法，我们在下文进行详细叙述，这里我们点到为止！现在，大家心里面就应该有这么一个蓝图，或者是基本框架，知道我们接下来将会沿着那个几个方向展开叙述！

创建Stream流

在Java中，你可以使用多种方式来创建Stream流。

  1. 从集合创建：

    使用集合类的 stream() 或 parallelStream() 方法可以创建对应的流。例如：

    List<String> list = Arrays.asList("apple", "banana", "orange");
Stream<String> streamFromList = list.stream();

  2. 从数组创建：

    使用 Arrays.stream() 方法可以从数组中创建流：

    String[] array = {"apple", "banana", "orange"};
Stream<String> streamFromArray = Arrays.stream(array);

  3. 通过Stream的静态方法创建：

    Stream 类提供了静态方法 of()，可以传入一系列元素来创建流：

    Stream<String> stream = Stream.of("apple", "banana", "orange");

  4. 使用Stream的generate和iterate方法：

    Stream 类还提供了 generate 和 iterate 方法，用于生成无限流：

    // 生成包含随机整数的无限流
Stream<Integer> infiniteStream = Stream.generate(() -> (int) (Math.random() * 100));// 从指定的起始值开始，按照某个规则生成无限流
Stream<Integer> sequentialStream = Stream.iterate(1, n -> n + 1);

  5. 通过文件生成流：

    java.nio.file.Files 类提供了静态方法 lines()，可以用来读取文件内容并生成流：

    Path path = Paths.get("example.txt");
Stream<String> fileLines = Files.lines(path);

  6. 使用正则表达式生成流：

    Pattern 类的 splitAsStream 方法可以根据正则表达式将字符串分割成流：

    String text = "apple,orange,banana";
Stream<String> textStream = Pattern.compile(",").splitAsStream(text);

Stream API中间操作

Stream API 提供了许多中间操作，用于对流进行转换、筛选和处理。

  1. filter：

    用于筛选元素，根据指定的条件保留符合条件的元素。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Stream<Integer> filteredStream = numbers.stream().filter(x -> x > 2);

  2. map：

    对流中的每个元素应用指定的函数，并将结果映射为一个新的元素。

    List<String> words = Arrays.asList("apple", "banana", "orange");
Stream<Integer> wordLengths = words.stream().map(String::length);

  3. flatMap：

    将流中的每个元素都转换为一个流，然后将这些流连接起来成为一个流。

    List<List<Integer>> numbers = Arrays.asList(Arrays.asList(1, 2),Arrays.asList(3, 4),Arrays.asList(5, 6)
);Stream<Integer> flatStream = numbers.stream().flatMap(List::stream);

  4. distinct：

    去除流中的重复元素。

    List<Integer> numbers = Arrays.asList(1, 2, 2, 3, 4, 4, 5);
Stream<Integer> distinctNumbers = numbers.stream().distinct();

  5. sorted：

    对流中的元素进行排序。

    List<Integer> numbers = Arrays.asList(3, 1, 4, 1, 5, 9, 2, 6);
Stream<Integer> sortedNumbers = numbers.stream().sorted();

  6. peek：

    对流中的每个元素执行操作，主要用于调试和观察流中的元素。

    List<String> words = Arrays.asList("apple", "banana", "orange");
Stream<String> peekStream = words.stream().peek(System.out::println);

  7. limit 和 skip：

    limit 用于截断流，保留指定数量的元素，而 skip 则用于跳过指定数量的元素。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Stream<Integer> limitedStream = numbers.stream().limit(3);
Stream<Integer> skippedStream = numbers.stream().skip(2);

  8. takeWhile 和 dropWhile（Java 9+）：

    takeWhile 返回元素满足指定条件的最长前缀，dropWhile 返回删除满足指定条件的最长前缀后的流。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Stream<Integer> takenWhileStream = numbers.stream().takeWhile(x -> x < 4);
Stream<Integer> droppedWhileStream = numbers.stream().dropWhile(x -> x < 4);

Stream API终端操作

Stream API 的终端操作用于触发对流的最终操作，产生结果或者引起副作用。

  1. forEach：

    对流中的每个元素执行指定的操作。

    List<String> words = Arrays.asList("apple", "banana", "orange");
words.stream().forEach(System.out::println);

  2. toArray：

    将流中的元素转换为数组。

    List<String> words = Arrays.asList("apple", "banana", "orange");
String[] wordArray = words.stream().toArray(String[]::new);

  3. reduce：

    对流中的元素进行归约操作，可以用于求和、求最大值、最小值等。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Optional<Integer> sum = numbers.stream().reduce(Integer::sum);

  4. collect：

    将流中的元素收集到一个集合中，例如 List、Set 或 Map。

    List<String> words = Arrays.asList("apple", "banana", "orange");
List<String> collectedWords = words.stream().collect(Collectors.toList());

  5. count：

    返回流中的元素数量。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
long count = numbers.stream().count();

  6. anyMatch、allMatch 和 noneMatch：

    用于检查流中是否存在满足指定条件的元素。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
boolean anyGreaterThanThree = numbers.stream().anyMatch(x -> x > 3);
boolean allGreaterThanTwo = numbers.stream().allMatch(x -> x > 2);
boolean noneGreaterThanFive = numbers.stream().noneMatch(x -> x > 5);

  7. findAny 和 findFirst：

    返回流中的任意一个元素或者第一个元素。

    List<String> words = Arrays.asList("apple", "banana", "orange");
Optional<String> anyWord = words.stream().findAny();
Optional<String> firstWord = words.stream().findFirst();

  8. min 和 max：

    返回流中的最小值或最大值。

    List<Integer> numbers = Arrays.asList(3, 1, 4, 1, 5, 9, 2, 6);
Optional<Integer> minNumber = numbers.stream().min(Integer::compare);
Optional<Integer> maxNumber = numbers.stream().max(Integer::compare);

注意事项

使用Stream API时，有一些需要注意的重要事项，以确保正确、高效地利用这一功能：

  1. 只能使用一次： 一个 Stream 实例只能被消费（执行终端操作）一次。如果你尝试对已经使用过的流进行其他终端操作，会抛出 IllegalStateException 异常。如果需要再次操作，可以重新创建一个新的流。

    List<String> words = Arrays.asList("apple", "banana", "orange");
Stream<String> wordStream = words.stream();// 正确的做法
long count = wordStream.count();// 错误的做法，会抛出IllegalStateException
long anotherCount = wordStream.count();

  2. 及早退出： 在处理大量数据时，及早退出可以提高性能。使用 anyMatch()、findFirst() 等终端操作时，一旦找到符合条件的元素，就会立即返回，不再继续处理后续元素。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
boolean anyGreaterThanThree = numbers.stream().anyMatch(x -> {System.out.println("Checking: " + x);return x > 3;
});

  3. 并行流的谨慎使用： Stream API 提供了并行流的支持，可以通过 parallel() 方法将顺序流转换为并行流。但并不是所有的场景都适合使用并行流，因为在某些情况下，并行流可能会导致性能下降，甚至出现并发问题。在并行流的使用上需要注意线程安全等问题。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
long count = numbers.parallelStream().filter(x -> x > 2).count();

  4. 避免可变状态： 在使用 map()、flatMap() 等操作时，避免修改流中的元素或者使用可变状态。这有助于确保流操作的无状态性，避免副作用。

    // 避免修改流中的元素
List<String> words = Arrays.asList("apple", "banana", "orange");
words.stream().map(String::toUpperCase).forEach(System.out::println);// 避免使用可变状态
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
int sum = numbers.stream().reduce(0, Integer::sum);

  5. 了解操作的性能特性： 不同的操作对性能的影响是不同的。例如，limit() 对顺序流的性能影响较小，但对并行流的性能影响较大。在选择操作时，了解其性能特性对于优化代码是有帮助的。

    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
Stream<Integer> limitedStream = numbers.stream().limit(3);  // 对顺序流影响较小，但对并行流影响较大

  6. 使用适当的数据结构： 在创建流时，选择适当的数据结构能够影响流操作的性能。例如，ArrayList 在顺序访问时性能较好，而 LinkedList 在随机访问时性能较好。

    List<String> words = new ArrayList<>(Arrays.asList("apple", "banana", "orange"));
Stream<String> wordStream = words.stream();

总体而言，了解Stream API的使用原则，结合具体的业务场景和性能需求，能够更好地利用Stream API完成任务。注意流的延迟计算特性，避免副作用，可以使代码更加清晰、可读，并提高代码的可维护性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/488265.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Leetcode 209.长度最小的子数组

Leetcode 209.长度最小的子数组

给定一个含有 n 个正整数的数组和一个正整数 target 。 找出该数组中满足其总和大于等于 target 的长度最小的 连续子数组 [numsl, numsl1, ..., numsr-1, numsr] &#xff0c;并返回其长度。如果不存在符合条件的子数组&#xff0c;返回 0 。 示例 1&#xff1a; 输入&…
阅读更多...
算法沉淀——动态规划之斐波那契数列模型（leetcode真题剖析）

算法沉淀——动态规划之斐波那契数列模型（leetcode真题剖析）

算法沉淀——动态规划之斐波那契数列模型 01.第 N 个泰波那契数02.三步问题03.使用最小花费爬楼梯04.解码方法 动态规划&#xff08;Dynamic Programming&#xff0c;简称DP&#xff09;是一种通过将原问题分解为相互重叠的子问题并仅仅解决每个子问题一次&#xff0c;将其解存…
阅读更多...
vue3前端项目开发,具备纯天然的防止爬虫采集的特征

vue3前端项目开发,具备纯天然的防止爬虫采集的特征

vue3前端项目开发,具备纯天然的防止爬虫采集的特征&#xff01;众所周知&#xff0c;网络爬虫可以在网上爬取到一些数据&#xff0c;很多公司&#xff0c;为了自己公司的数据安全&#xff0c; 尤其是web端项目&#xff0c;不希望被爬虫采集。那么&#xff0c;您可以使用vue技术…
阅读更多...
Linux快速修改ip地址

Linux快速修改ip地址

Linux修改IP配置 一 、查找ip配置文件 ifcfg-ens33二、编辑 vi ifcfg-ens33文件三、重启网络或者重启系统 一 、查找ip配置文件 ifcfg-ens33 cd /etc/sysconfig/network-scripts/ls //查看network-scripts文件夹下面的文件二、编辑 vi ifcfg-ens33文件 vi ifcfg-ens33注意&…
阅读更多...
阿里云国际-在阿里云服务器上快速搭建幻兽帕鲁多人服务器

阿里云国际-在阿里云服务器上快速搭建幻兽帕鲁多人服务器

幻兽帕鲁是最近流行的新型生存游戏。该游戏一夜之间变得极为流行&#xff0c;同时在线玩家数量达到了200万。然而&#xff0c;幻兽帕鲁的服务器难以应对大量玩家的压力。为解决这一问题&#xff0c;幻兽帕鲁允许玩家建立专用服务器&#xff0c;其提供以下优势&#xff1a; &am…
阅读更多...
【mysql】1000w数据量的分页查询SQL，如何优化提升性能？

【mysql】1000w数据量的分页查询SQL，如何优化提升性能？

文章目录 优化场景特别注意&#xff01;&#xff01;&#xff01;有前提&#xff0c;谨慎使用 优化场景 当表数据量非常大时&#xff0c;需要进行分页查询如果慢的时候&#xff0c;可以考虑优化下。 假设一页展示10条&#xff0c;查询第10w条后面的数据时候变慢了… 优化思路&…
阅读更多...
Sora是什么？

Sora是什么？

文章目录 前言Sora是什么&#xff1f;功能特色优点 缺点Sora模型的工作原理如何使用Sora模型Sora模型的应用场景Sora模型带来的问题虚假信息版权问题 后记 前言 Sora是美国人工智能研究公司OpenAI发布的一款令人惊叹的人工智能文生成视频大模型。近年来&#xff0c;人工智能技…
阅读更多...
Java学习笔记------继承

Java学习笔记------继承

继承 Java中提供了一个关键字extends&#xff0c;用这个关键字&#xff0c;我们可以让一个类和另一个类建立继承关系 如图&#xff0c;Student和Teacher类中除了study&#xff08;&#xff09;和teacher&#xff08;&#xff09;两个成员函数不同&#xff0c;其他重复了&…
阅读更多...
会声会影2024最新官方旗舰版下载及功能讲解

会声会影2024最新官方旗舰版下载及功能讲解

会声会影支持的视频格式非常多样&#xff0c;包括但不限于&#xff1a;AVI、MPEG-1、MPEG-2、AVCHD、MPEG-4、H.264、BDMV、DV、HDV、DivX、QuickTime、RealVideo、Windows Media Format、MOD&#xff08;JVC MOD 文件格式&#xff09;、M2TS、M2T、TOD、3GPP、3GPP2 等。 这些…
阅读更多...
【LNMP】云导航项目部署及环境搭建(复杂)

【LNMP】云导航项目部署及环境搭建(复杂)

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、项目介绍1.1项目环境架构LNMP1.2项目代码说明 二、项目环境搭建2.1 Nginx安装2.2 php安装2.3 nginx配置和php配置2.3.1 修改nginx文件2.3.2 修改vim /etc/p…
阅读更多...
基于PostGIS的慢查询引起的空间索引提升实践

基于PostGIS的慢查询引起的空间索引提升实践

目录 前言 一、问题定位 1、前端接口定位 2、后台应用定位 3、找到问题所在 二、空间索引优化 1、数据库查询 2、创建空间索引 3、geography索引 4、再看前端响应 总结 前言 这是一个真实的案例&#xff0c;也是一个新入门的工程师很容易忽略的点。往往在设计数据库的…
阅读更多...
vue2+element医院安全（不良）事件报告管理系统源代码

vue2+element医院安全（不良）事件报告管理系统源代码

目录 安全不良事件类型 源码技术栈 医院安全&#xff08;不良&#xff09;事件报告管理系统采用无责的、自愿的填报不良事件方式&#xff0c;有效地减轻医护人员的思想压力&#xff0c;实现以事件为主要对象&#xff0c;可以自动、及时、实际地反应医院的安全、不良、近失事件…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023