介绍java stream流中的peek。举个例子
时间: 2023-10-14 09:27:08 浏览: 41
Java 8中引入了Stream API,它提供了一种更为便捷的处理集合的方式。Stream中的peek方法可以让我们在流的处理过程中,查看流中的元素,而不会改变流中元素的值。
举个例子,假设有如下一个List:
```java
List<Integer> nums = Arrays.asList(1, 2, 3, 4, 5);
```
我们可以使用peek方法在流中查看每个元素的值:
```java
List<Integer> result = nums.stream()
.peek(num -> System.out.println("Processing number: " + num))
.collect(Collectors.toList());
```
在这个例子中,我们使用peek方法输出每个元素的值,但是并不改变其值。输出结果如下:
```
Processing number: 1
Processing number: 2
Processing number: 3
Processing number: 4
Processing number: 5
```
最终,我们将这些元素收集到一个新的List中,并返回给result变量。需要注意的是,peek方法不会对流进行任何修改,它只是提供了一种方便的方式,让我们在流的处理过程中查看元素。
相关问题
stream流中peek的作用
在Java Stream中,peek()方法是一种非终端操作,它允许你在流的每个元素上执行一个操作,而不会改变流的内容。peek()方法主要用于调试和观察流的中间状态,而不会对流的内容进行修改。它可以用于打印元素的值、记录日志、调试等。下面是一个使用peek()方法的例子:
```java
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
List<Integer> result = numbers.stream()
.peek(System.out::println) // 打印每个元素的值
.map(n -> n * 2) // 对每个元素乘以2
.collect(Collectors.toList());
```
在上面的例子中,我们首先创建了一个包含整数的列表。然后,我们使用stream()方法将其转换为一个流。接下来,我们使用peek()方法打印每个元素的值。然后,我们使用map()方法将每个元素乘以2。最后,我们使用collect()方法将结果收集到一个列表中。
注意,peek()方法是一种非终端操作,它不会触发流的处理。只有当你调用一个终端操作(如collect())时,流才会被处理。
stream流peek
Stream流的peek方法用于在流的每个元素上执行一个操作,而不会改变流中的元素。它接收一个Consumer函数作为参数,该函数对每个元素执行操作并返回一个修改后的流。peek方法可用于调试、观察流中元素的处理过程,但不会改变流的内容。
例如,如果我们有一个包含整数的流,并希望在处理每个元素时打印出元素的值,可以使用peek方法来实现:
```java
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
numbers.stream()
.peek(num -> System.out.println("Processing element: " + num))
.forEach(System.out::println);
```
在上面的例子中,peek方法用于打印每个元素的值,并且不会改变流中的元素。输出结果将是:
```
Processing element: 1
1
Processing element: 2
2
Processing element: 3
3
Processing element: 4
4
Processing element: 5
5
```
请注意,在流的处理过程中,peek方法是一个中间操作,它并不会触发流的终止操作。因此,我们在上面的例子中通过forEach方法来触发流的终止操作,以打印出流中的元素。
引用:
:主要负责新建一个Stream流,或者基于现有的数组、List、Set、Map等集合类型对象创建出新的Stream流。API功能说明stream()创建出一个新的stream串行流对象parallelStream()创建出一个可并行执行的stream流对象Stream.of()通过给定的一系列元素创建一个新的Stream串行流对象
:执行的时候,结果如下:
6 -----下面会报错-----
java.lang.IllegalStateException: stream has already been operated upon or closed
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:229)
at java.util.stream.ReferencePipeline.anyMatch(ReferencePipeline.java:449)
at com.veezean.skills.stream.StreamService.testHandleStreamAfterClosed(StreamService.java:153)
at com.veezean.skills.stream.StreamService.main(StreamService.java:176)
-----上面会报错-----