Java流中的中间操作[重复]

Question

在 java 8 中，我使用 Streams 打印输出，但大小为 0。为什么？

public class IntermediateryAndFinal {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("one", "two", "three", "four", "five");

        Predicate<String> p1 = Predicate.isEqual("two");
        Predicate<String> p2 = Predicate.isEqual("three");

        List<String> list = new ArrayList<>();

        stream.peek(System.out::println)
            .filter(p1.or(p2))
            .peek(list::add);
        System.out.println("Size = "+list.size());
    }
}

Answer 1

理想情况下，您不应该改变外部列表，而是可以使用Collectors.toList() 将其收集到列表中：

List<String> list = stream.peek(System.out::println)
            .filter(p1.or(p2))
            .collect(Collectors.toList()); // triggers the evaluation of the stream
System.out.println("Size = "+list.size());

在您的示例中，只有在终端操作像

时才会评估流

allMatch()
anyMatch() 
noneMatch() 
collect() 
count() 
forEach() 
min() 
max() 
reduce()

遇到了。

Answer 2

由于您尚未完成流操作，即peek 是一个中间操作。您必须使用 终端操作 才能继续执行。

建议：改为使用collect等终端操作进行此类操作

List<String> list = stream.peek(System.out::println)
        .filter(p1.or(p2))
        .collect(Collectors.toList());

另外：添加peek 帖子filter 来观察值可能有点难以观察，如下代码

List<String> list = stream.peek(System.out::println)
        .filter(p1.or(p2))
        .peek(System.out::println) // addition
        .collect(Collectors.toList());

输出看起来像：

one
two
two // filtered in
three
three // filtered in
four
five

Answer 3

流是懒惰的。你可以调用类似forEach的终端操作：

stream.peek(System.out::println)
      .filter(p1.or(p2))
      .forEach(list::add);

如果您想使用peek 作为中间操作进行调试，那么您必须在之后调用终端操作：

stream.peek(System.out::println)
      .filter(p1.or(p2))
      .peek(list::add);
      .<any terminal operation here>();

顺便说一句，如果您只想将所有过滤后的值存储在一个列表中，那么最好使用collect(toList())。

Answer 4

您对filter 和peek 所做的所有工作都是设置一系列操作以应用于流。您实际上还没有使它们中的任何一个运行。您必须添加一个终端操作，例如count。 （另一个答案建议使用forEach 添加到列表中，但我认为您专门尝试使用中间操作peek。）