Stream流的中间操作和终端操作

最近在写代码时发现一个很有意思的问题

问题代码：

 1 // 1.准备一个集合，排序。
 2         List<Movie> movies = new ArrayList<>();
 3         movies.add(new Movie("摔跤吧，爸爸", 9.5, "阿米尔汗"));
 4         movies.add(new Movie("三傻宝莱坞", 8.5, "阿米尔汗2"));
 5         movies.add(new Movie("三傻宝莱坞", 8.5, "阿米尔汗2"));
 6         movies.add(new Movie("阿甘正传", 7.5, "汤姆汉克斯"));
 7 // map加工方法(映射)：把流上的数据加工成新数据。
 8         System.out.println("-----------------------------------------------");
 9         //第一次map
10         movies.stream().map( movie-> {
11                 movie.setName("电影："+movie.getName());
12                 return movie;
13             }
14         );
15         //第二次map 加 foreach
16         movies.stream().map( m -> {
17                 m.setName("黑马：" + m.getName());
18                 return m;
19         }).forEach(System.out::println);
20 21 
22         System.out.println("原始数据" +movies);

输出结果：

Movie{name='黑马：摔跤吧，爸爸', score=9.5, actor='阿米尔汗'}
Movie{name='黑马：三傻宝莱坞', score=8.5, actor='阿米尔汗2'}
Movie{name='黑马：三傻宝莱坞', score=8.5, actor='阿米尔汗2'}
Movie{name='黑马：阿甘正传', score=7.5, actor='汤姆汉克斯'}
原始数据[Movie{name='黑马：摔跤吧，爸爸', score=9.5, actor='阿米尔汗'}, Movie{name='黑马：三傻宝莱坞', score=8.5, actor='阿米尔汗2'}, Movie{name='黑马：三傻宝莱坞', score=8.5, actor='阿米尔汗2'}, Movie{name='黑马：阿甘正传', score=7.5, actor='汤姆汉克斯'}]

• 第一个map()方法中没有使用collect()方法来收集加工后的流，而是直接调用了第二个map()方法。这样会导致第一个map()方法的结果被丢弃，可为什么第二个map()方法加上forEach会改变原始数据呢？

为了弄明白其中缘由我查询了一些资料，究其原因和Stream流的中间操作和终端操作有关

在Java 8中，stream是一种抽象的数据结构，它表示一个元素序列，可以对这些元素进行各种操作，比如过滤、映射、排序、聚合等。stream本身并不存储数据，而是从一个源（比如集合、数组、文件等）获取数据，并按照一定的规则处理数据，然后输出到一个目标（比如另一个集合、数组、文件等）。

stream有两种类型的操作：中间操作和终端操作。中间操作是指返回一个新的stream的操作，比如map、filter、sorted等。终端操作是指返回一个非stream的结果的操作，比如forEach、collect、reduce等。

当我们对一个stream进行中间操作时，并不会立即执行这些操作，而是会创建一个新的stream，并记录下这些操作。只有当我们对这个stream进行终端操作时，才会触发这些中间操作的执行，这种机制称为惰性求值

例如，当我们写下以下代码时： List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);  list.stream().map(i -> i * 2); 

并不会立即对list中的每个元素乘以2，而是会返回一个新的stream，并记录下map这个中间操作。只有当我们对这个stream进行终端操作时，比如：

List<Integer> newList = list.stream().map(i -> i * 2).collect(Collectors.toList());

才会触发map这个中间操作的执行，并把结果收集到一个新的列表中。

那么，为什么在后面调用forEach也可以保存修改的对象呢？这是因为forEach是一种特殊的终端操作，它不会返回任何结果，而是对stream中的每个元素执行一个消费者函数（Consumer），这个函数可以对元素进行任何操作，包括修改元素的状态。

例如，当我们写下以下代码时：

List<SampleDTO> list = ...; // 假设list是一个SampleDTO对象的列表
list.stream().forEach(s -> s.setText(s.getText() + "xxx")); // 对每个对象的text属性追加"xxx"

就会触发forEach这个终端操作的执行，并对list中的每个对象执行消费者函数s -> s.setText(s.getText() + “xxx”)，这个函数会修改对象的text属性。因此，在执行完这段代码后，list中的每个对象都会被修改。

需要注意的是，虽然forEach可以修改对象的状态，但并不意味着它可以修改stream的源。例如，以下代码是错误的：

List<SampleDTO> list = ...; // 假设list是一个SampleDTO对象的列表
list.stream().forEach(s -> list.remove(s)); // 尝试删除每个对象

这段代码会抛出ConcurrentModificationException异常，因为它试图在遍历list的同时修改list，这是不允许的。

 总之，当我们在后面调用forEach也可以保存修改的对象，是因为forEach是一种特殊的终端操作，它可以对stream中的每个元素执行任何操作，包括修改元素的状态。但是，我们应该避免使用forEach来修改元素的状态，因为这样会破坏函数式编程的原则和可读性。我们应该尽量使用其他终端操作来返回新的结果，而不是修改原来的结果。