详细分析Java中的list.foreach()和list.stream().foreach()

这篇具有很好参考价值的文章主要介绍了详细分析Java中的list.foreach()和list.stream().foreach()。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

前言

典故来源于项目中使用了两种方式的foreach,后面尝试体验下有何区别!

先看代码示例:

使用List的forEach

import java.util.Arrays;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 使用List的forEach
        data.forEach(element -> {
            System.out.println("Element: " + element);
        });
    }
}

使用Stream API的forEach

import java.util.Arrays;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 使用Stream API的forEach
        data.stream().forEach(element -> {
            System.out.println("Element: " + element);
        });
    }
}

两者输出结果都为如下:

java list foreach,Java,java,list,stream,foreach

既然两个都输出差不多的结果,但两者还是稍微有些小区别,具体看下文!

1. 基本知识

  1. forEach() 是List接口的一部分,用于对列表中的每个元素执行给定的操作。与Stream API的 forEach 不同,list的 forEach 不支持并行处理,因此它在处理大量数据时可能不如Stream API高效。
    适用于简单的迭代和操作,不需要复杂的流处理。

  2. stream().forEach() 是Stream API的一部分,用于对流中的每个元素执行给定的操作。使用Stream API的 forEach 允许进行更多的操作,例如过滤、映射等,因为你可以在流上链式调用其他方法。
    Stream API提供了更多的灵活性和功能,适用于处理大量数据或进行复杂的操作。

两者更多的区别可看下表:

代码块 概念 作用 差异之处 适用场景
list.foreach() List接口中的方法,用于对列表中的每个元素执行给定的操作 1.通过 forEach(),可以对列表中的每个元素进行遍历,并在每个元素上执行指定的操作。

2.主要用于简单的迭代和操作,适用于不需要复杂流处理的场景。
1.并行处理: List的 forEach 不支持并行处理,因此在处理大量数据时可能不如Stream API高效。Stream API的并行处理机制可以更好地利用多核处理器的性能。

2.功能限制: List的 forEach 主要用于简单的迭代操作,而没有提供像Stream API那样的丰富中间操作和终端操作,限制了其在复杂数据处理场景中的应用。
适用于简单的遍历和操作,例如对列表中的元素进行打印、计算简单统计量等。

不适用于需要复杂处理逻辑的情况。
stream().foreach() Java 8引入的Stream API中的方法,用于对流中的每个元素执行给定的操作。 1.通过 forEach(),可以对流中的每个元素进行遍历,并在每个元素上执行指定的操作。

2.Stream API提供了一种更为函数式的方式来处理数据,允许链式调用其他方法,如过滤、映射、排序等。
1.链式调用: 使用Stream API的 forEach 允许在流上进行链式调用其他方法,使得可以进行更多的操作。这种链式调用是函数式编程的一种特征,使代码更为灵活和表达性强。

2.功能丰富: Stream API提供了更多的中间操作和终端操作,例如 map、filter、reduce 等,这些操作可以组合使用,实现更复杂的数据处理逻辑。
适用于处理大量数据或进行复杂的操作,例如对数据进行变换、过滤、聚合等。

Stream API的并行处理机制也使得在多核处理器上能够更高效地处理大规模数据。

总结:

2. 差异之处

此处的差异之处主要讲解stream().foreach()list.foreach()多的点

2.1 执行顺序

stream流中如果结合parallelStream(),会有不一样的特性!

import java.util.Arrays;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 使用Stream API中的parallelStream  forEach
        data.parallelStream().forEach(element -> {
            System.out.println("Element: " + element);
        });
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

在使用 parallelStream() 进行并行处理时,元素的处理顺序可能不会按照原始列表中的顺序输出。
并行流会将数据分成多个块,然后并行处理这些块,最后将结果合并。

因此,并行处理的结果可能在不同的块之间交错,导致输出的顺序不再按照原始列表的顺序。

想要保持顺序,可以使用 forEachOrdered() 方法,它会保证按照流的遍历顺序输出结果(并行流的情况下保持元素的遍历顺序,但可能会牺牲一些并行处理的性能优势)。示例如下:

import java.util.Arrays;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 使用Stream API的parallelStream().forEachOrdered
        data.parallelStream().forEachOrdered(element -> {
            System.out.println("Element: " + element);
        });
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

2.2 串行并行

对应上章节继续科普parallelStream(),一般来说并行的输出速度比较快,用于对顺序输出不讲究,但是大量的数据处理可以用这个!

对于少量的数据来说,效果不明显,甚至会高于list.foreach(),所以根据情况而来,一般数据处理多,可以应用parallelStream()

import java.util.ArrayList;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<Integer> numbers = new ArrayList<>();
        for (int i = 1; i <= 1000000; i++) {
            numbers.add(i);
        }

        // 使用 Stream.forEach 进行并行处理
        long startTime = System.currentTimeMillis();

        numbers.parallelStream().forEach(element -> {
            // 模拟一些耗时的操作
            Math.pow(element, 2);
        });

        long endTime = System.currentTimeMillis();
        System.out.println("Time taken with Stream.forEach (parallel): " + (endTime - startTime) + " ms");
    }
}

截图如下所示:

java list foreach,Java,java,list,stream,foreach

原本以为使用list.foreach(),时间会更长,反而时间更短:

import java.util.ArrayList;
import java.util.List;

public class Demo {
    public static void main(String[] args) {
        List<Integer> numbers = new ArrayList<>();
        for (int i = 1; i <= 1000000; i++) {
            numbers.add(i);
        }

        // 使用 List.forEach 进行串行处理
        long startTime = System.currentTimeMillis();

        numbers.forEach(element -> {
            // 模拟一些耗时的操作
            Math.pow(element, 2);
        });

        long endTime = System.currentTimeMillis();
        System.out.println("Time taken with List.forEach (sequential): " + (endTime - startTime) + " ms");
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

可能是由于数据规模较小、并行处理带来的额外开销以及模拟的耗时操作较短,导致并行流的性能没有得到有效提升。

并行处理的优势在于处理大规模数据时更为显著。

2.3 复杂数据处理

Stream API提供了丰富的中间操作和终端操作,使得能够进行更复杂的数据处理。

下面举例说明 filter()、map()、reduce() 这几个常用的操作方法。

  • filter() 用于对流中的元素进行过滤,只保留满足某个条件的元素:
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 过滤出长度大于3的元素
        List<String> filteredList = data.stream()
                .filter(element -> element.length() > 3)
                .collect(Collectors.toList());

        System.out.println("Filtered List: " + filteredList);
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

  • map() 用于对流中的每个元素进行映射转换,生成一个新的流:
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three", "Four", "Five");

        // 将每个元素转换为大写
        List<String> uppercasedList = data.stream()
                .map(String::toUpperCase)
                .collect(Collectors.toList());

        System.out.println("Uppercased List: " + uppercasedList);
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

  • reduce() 用于将流中的元素逐个进行操作,最终得到一个结果
import java.util.Arrays;
import java.util.List;
import java.util.Optional;

public class Demo {
    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

        // 对所有元素求和
        Optional<Integer> sum = numbers.stream()
                .reduce((x, y) -> x + y);
        
        sum.ifPresent(result -> System.out.println("Sum: " + result));
    }
}

使用 Optional<Integer> 主要是为了处理可能没有元素的情况,避免返回 null。

考虑到 numbers 可能为空,如果直接使用 reduce((x, y) -> x + y),当 numbers 为空时,会得到 null,而这可能导致空指针异常。

截图如下:

java list foreach,Java,java,list,stream,foreach

拓展1
对于上述代码中,都有使用到Collectors.toList()

Collectors.toList() 是Collectors 工具类提供的一个静态方法,它用于将流中的元素收集到一个 List 集合中。
在Stream API中,对流进行一系列的操作后,通常会希望将结果收集到一个集合中,以便后续的操作或输出。

在实际应用中,还可以使用其他的 Collectors 方法,如 toSet()、toMap() 等,以便根据需求将元素收集到不同的集合类型中。

拓展2
对于上述reduce中,使用到了Optional

Optional 是Java 8引入的一个类,用于处理可能为null的值。
它的设计目的是避免使用null,减少空指针异常的发生,并提供更安全、清晰的代码。

在上述代码中,通过使用 Optional<Integer>,可以更安全地处理可能为空的情况。如果 numbers 为空,reduce 操作的结果将是 Optional.empty(),而不是 null。

import java.util.Arrays;
import java.util.List;
import java.util.Optional;

public class ReduceWithOptionalExample {
    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

        // 使用Optional处理可能为空的情况
        Optional<Integer> sum = numbers.stream()
                .reduce((x, y) -> x + y);

        // 判断Optional是否包含值
        if (sum.isPresent()) {
            System.out.println("Sum: " + sum.get());
        } else {
            System.out.println("The list is empty.");
        }
    }
}

2.4 CRUD集合

当使用 list.foreach()stream().foreach() 进行遍历操作时,如果在遍历过程中对集合进行了增、删、改的操作,可能会导致 ConcurrentModificationException 异常。

一、list.foreach()的增删:

增加数据的Demo代码:

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = new ArrayList<>();
        data.add("One");
        data.add("Two");
        data.add("Three");

        // 使用 List.forEach 遍历,并在遍历过程中增加元素
        data.forEach(element -> {
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                data.add("Four"); // 在遍历过程中增加元素
            }
        });
    }
}

以及删除数据Demo:

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = new ArrayList<>();
        data.add("One");
        data.add("Two");
        data.add("Three");

        // 使用 List.forEach 遍历,并在遍历过程中删除元素
        data.forEach(element -> {
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                data.remove(element); // 在遍历过程中删除元素,可能导致异常
            }
        });
    }
}

最终的结果截图如下:

java list foreach,Java,java,list,stream,foreach


二、list.stream().foreach()的增删:

增加数据的Demo代码:

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = new ArrayList<>();
        data.add("One");
        data.add("Two");
        data.add("Three");

        // 使用 Stream.forEach 遍历,并在遍历过程中增加元素
        data.stream().forEach(element -> {
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                data.add("Four"); // 在遍历过程中增加元素
            }
        });
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach
以及删除数据Demo:

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = new ArrayList<>();
        data.add("One");
        data.add("Two");
        data.add("Three");

        // 使用 Stream.forEach 遍历,并在遍历过程中删除元素
        data.stream().forEach(element -> {
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                data.remove(element); // 在遍历过程中删除元素,可能导致异常
            }
        });
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

通过上述四个程序的执行结果,可以得到什么体会呢???

stream().foreach()在操作集合的CRUD的时候,执行错误之后,还是会迭代整个列表,才看到异常

这也证明stream().foreach()为并行执行处理数据,而不是串行

那有办法解决这种异常的情况么,又能对集合进行CRUD!(答案是有的,可看如下正文)

2.5 迭代器

通过上述的阅读,急需需要一个对集合的CRUD做一个安全性的迭代!
于是有了如下的解决方式:

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = new ArrayList<>();
        data.add("One");
        data.add("Two");
        data.add("Three");

        // 使用迭代器遍历,并在条件满足时删除元素
        Iterator<String> iterator = data.iterator();
        while (iterator.hasNext()) {
            String element = iterator.next();
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                iterator.remove(); // 尝试在不支持结构性修改的列表上进行删除操作,抛出异常
            }
        }

        System.out.println("Modified List: " + data);
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

3. 总结

总结起来,对于上面的代码学习,主要涉及了两种遍历集合的方式:List.forEach() 和 List.stream().forEach()。下面对这两种方式的区别进行总结:

List.forEach() 方法:

  1. 遍历是在当前线程中按顺序执行的,对集合元素的操作是同步的。

  2. 适用于简单的、顺序执行的遍历操作。

  3. 不支持并行操作,不保证源数据的顺序。

List.stream().forEach() 方法:

  1. 可以利用并行流进行多线程处理,提高遍历效率,不保证源数据的顺序。

  2. 适用于更复杂的、并行处理的遍历操作,可以配合 Stream 的其他操作进行更灵活的数据处理。

4. 彩蛋

对于上述中的代码,有一个需要注意的点:
不管是list.foreach()还是list.stream().foreach(),集合的CRUD都会出现会爆:Exception in thread "main" java.lang.UnsupportedOperationException的错误,举一个例子。

import java.util.*;

public class Demo {
    public static void main(String[] args) {
        List<String> data = Arrays.asList("One", "Two", "Three");

        // 使用 List.forEach 遍历,并在遍历过程中删除元素
        data.forEach(element -> {
            System.out.println("Element: " + element);
            if (element.equals("Two")) {
                data.remove(element); // 在遍历过程中删除元素,可能导致异常
            }
        });
    }
}

截图如下:

java list foreach,Java,java,list,stream,foreach

主要的原因在于:

Arrays.asList("One", "Two", "Three", "Four", "Five") 创建的列表是由数组支持的固定大小的列表。

这意味着该列表不支持结构性修改操作(如添加、删除),并且会在尝试进行这些操作时抛出UnsupportedOperationException 异常。文章来源地址https://www.toymoban.com/news/detail-857900.html

到了这里,关于详细分析Java中的list.foreach()和list.stream().foreach()的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • java中 list 集合 foreach 时删除会报错

    在使用Java中的List集合的foreach循环进行元素遍历时,不能在循环体内删除元素,否则会抛出ConcurrentModificationException异常。 这是因为在使用foreach循环时,Java会使用迭代器来遍历集合中的元素,而在集合被修改时,迭代器可能会失效,从而导致ConcurrentModificationException异常的抛

    2024年02月15日
    浏览(35)
  • Java的list.forEach能否实现continue和break

    Java的forEach是一个方便的遍历集合的方法,它的实现方式不允许使用continue语句来跳过某些元素,但可以使用return语句来达到类似continue的效果,也就是说在需要使用continue;的位置直接使用return;替代即可。例如: forEach循环是一种基于迭代器的循环方式,不支持使用break语句来

    2024年02月16日
    浏览(45)
  • Java中通过List中的stream流去匹配相同的字段去赋值,避免for循环去查询数据库进行赋值操作

    Q :上面两个列表怎么使用流,根据equipmentDeviceMessageInfo中的phone字段去匹配userList 中的phone字段再获取userList 中是name赋值给equipmentDeviceMessageInfo 中的name。 A :以前的写法是通过for循环遍历一个一个去查询赋值,这样的话如果数据多的话一个一个遍历会查询的话肯定是很慢的,

    2024年02月07日
    浏览(48)
  • java List的stream()方法解析

    一、简介 常用的4种stream()用法。 (1) list.stream().map().collect() 方法,可以获取list中JavaBean的某个字段,转成一个新的list。 (2) list.stream().filter().map().collect() 方法,可以对list中的JavaBean进行筛选,保留符合条件的 JavaBean,然后将JavaBean中的某个字段,转成一个新的list。 (3) list.st

    2024年01月18日
    浏览(43)
  • Java中list集合stream流去重

    准备类: (1)根据单字段name去重 (2)根据多字段name price去重 (3)示例 输出打印结果

    2024年02月09日
    浏览(56)
  • java中Stream转成List类型如下写代码?

    在Java中,将Stream转换为List类型可以使用 Collectors.toList() 方法。以下是示例代码: javaCopy code import java.util.List; import java.util.stream.Collectors; import java.util.stream.Stream; public class StreamToListExample { public static void main(String[] args) { StreamInteger stream = Stream.of(1, 2, 3, 4, 5); ListInteger list = str

    2024年02月12日
    浏览(57)
  • JAVA中对list使用stream对某个字段求和

    对于List对象 或者ListMapString,integer等类型的数组,如何快速的求出list数组中某个对象的某个属性的和,平均数,统计数,最大值,最小值,等: 使用 XXXSummaryStatistics统计类实现: 运行结果如下: 相应的还有DoubleSummaryStatistics, LongSummaryStatistics

    2024年02月14日
    浏览(47)
  • JAVA8中list.stream()的一些简单使用

    为函数式编程而生。对stream的任何修改都不会修改背后的数据源,比如对stream执行过滤操作并不会删除被过滤的元素,而是会产生一个不包含被过滤元素的新stream。 stream上的操作并不会立即执行,只有等到用户真正需要结果的时候才会执行。 stream只能被使用一次,一旦遍历

    2024年02月03日
    浏览(45)
  • Java8-使用stream.sorted()对List排序

    1.流的定义 Stream 中文称为 “流”,通过将集合转换为这么一种叫做 “流” 的元素序列,通过声明性方式,能够对集合中的每个元素进行一系列并行或串行的操作! 如果流中的元素的类实现了 Comparable 接口,即有自己的排序规则,那么可以直接调用 sorted() 方法对元素进行排

    2024年02月16日
    浏览(56)
  • Java Stream:List分组成Map或LinkedHashMap

    在Java中,使用Stream API可以轻松地对集合进行操作,包括将List转换为Map或LinkedHashMap。本篇博客将演示如何利用Java Stream实现这两种转换,同时假设List中的元素是User对象。 List转Map有两种Map格式,分别是 MapString, User 和 MapString, List ,下面我将分别展示: 转换成MapString, User我们

    2024年02月03日
    浏览(52)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包