Java流关闭方法模糊行为

Question

给定这个Java类：

class MyClass {
    private int value;

    public MyClass(int value) {
        this.value = value;
    }

    public void setValue(int value) {
        this.value = value;
    }

    public int getValue() {
        return this.value;
    }

    @Override
    public String toString() {
        return "Value: " + value;
    }
}

给出以下Java代码：

Consumer<MyClass> cons = mc -> mc.setValue(mc.getValue() * mc.getValue());

List<MyClass> list = new ArrayList<>();
list.add(new MyClass(1));
list.add(new MyClass(2));
list.add(new MyClass(3));

System.out.println(list);

我得到了这个输出：[值：1，值：2，值：3]

当我运行这段代码时：

list.stream().peek(cons).close();   //1
System.out.println(list);

我期望得到输出[Value:1，Value:4，Value:9]，但我得到了[Value:1，Value:2，Value:3]，所以列表中的元素没有被修改。

但是当我运行这个时：

list.stream().forEach(cons);        //2

这是：

list.stream().peek(cons).count();   //3

我两次都得到了我期望的输出（[Value： 1， Value： 4， Value： 9]）

为什么第//1行没有给我这个输出？我想这是因为close（）：这个方法是如何工作的？

谢谢你的支持。

Answer 1

peek是一种中间操作，不会触发流处理管道，除非其中有终端操作符。所以声明，

list.stream().peek(cons).close();

没有终端操作，并且根本不会触发流管道，因此不会执行使用者，从而导致您观察到的结果。该列表保持不变。然而，这不是由于流中的关闭方法造成的。

在其他两种情况下，

list.stream().forEach(cons);        
list.stream().peek(cons).count();  

您有每个和计数的终端操作，因此执行消费者导致修改原始列表。

Answer 2

关闭，无论是否有终端操作都会被触发；如果它用于尝试使用资源或关闭会在流本身上调用；但无论哪种方式，它都不是终端操作。所以它既不是中间一个，也不是终端一个——它有点特殊。

    Stream<Integer> s2 = Stream.of(1, 2, 3);
    s2.onClose(() -> System.out.println("Closing 2"));
    s2.close(); // will print Closing 2

但也看到了这一点：

    try (Stream<Integer> s = Stream.of(1, 2, 3)) {
        s.onClose(() -> System.out.println("Closing"));
        s.filter(x -> x > 1)
         .peek(x -> System.out.println("foud one"));
    }

运行此命令，您自己可以看到，在第二个示例中，没有触发peek，但关闭。

因此，为了回答您的问题，正确的措辞应该是：close不是终端操作，因此您的流管道不会执行。