java - 在try-with-resources block 中关闭了Java 8 flatMapped流

This question already has answers here:

Java 8 Streams and try with resources

(4个答案)

在8个月前关闭。

我有两种方法可以返回列表中字符串的长度，如下所示；

    private Stream<Integer> method1(List<String> list) {
        try (final Stream<String> myStream = list.stream()) {
            return myStream.map(String::length);
        }
    }

和

    private Stream<Integer> method2(List<String> list) {
        try (final Stream<String> myStream = list.stream()) {
            return myStream.map(String::length).flatMap(Stream::of);
        }
    }

当我尝试使用其中任一方法的结果流时；

    List<Integer> collect = method1(list).collect(Collectors.toList());

要么

    List<Integer> collect = method2(list).collect(Collectors.toList());

我懂了

    Exception in thread "main" java.lang.IllegalStateException: source already consumed or closed

现在，我知道在try-with-resources块中使用流并不常见。但是在我的真实代码中，我在try-with-resources中使用Stream<Path> paths = Files.walk(Path.of(myPath))。在Files.walk(..)方法的文档中说

必须在try-with-resources语句或类似的控制结构中使用此方法，以确保在流的操作完成后立即关闭流的打开目录。

上面的代码仅是显示问题的示例。

我的问题是，尽管我使用map和flatMap返回新的流，但为什么我的流仍然关闭。我是否期望这两个方法返回新的Stream实例，因此仅myStream被关闭，而不是map操作返回的一个实例，我是否错了？我对monad有一个模糊的理解，但是map和flatMap方法的行为是否意味着Stream不是真正的monad？

最佳答案

一旦stream块完成，就将关闭try。

因为Stream<T>扩展了BaseStream<T, Stream<T>>和BaseStream扩展了AutoCloseable
为什么我在块中创建的Stream实例也被关闭

因为在块中创建的新Stream实例是链式嵌套的myStream流，并在myStream(外部流)关闭后立即关闭。您可以使用onClose进行验证，如下所示，

privat Stream<Integer> method1(List<String> list) {
    try (final Stream<String> myStream = list.stream()) {
        Stream<Integer> integerStream = myStream.onClose(r)
                .map(String::length).onClose(r1);
        return integerStream;
    }
}
Runnable r = ()->{
    System.out.println("closed main stream...");
};
Runnable r1 = ()->{
    System.out.println("closed map stream...");
};

关于java - 在try-with-resources block 中关闭了Java 8 flatMapped流，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59730279/

上一篇：java - 有没有办法在 Hazelcast 中使用自定义执行程序？

下一篇：java - AOP编程——ProceedingJoinPoint只支持around advice

相关文章：

java - 在另一个字符串中替换最后一次出现的字符串

java - 使用 MQTT (paho) + activeMQ 接收消息的正确方式是怎样的？

java - 使用可选项重写服务请求

java - 从字符串创建 ascii 数字字符串

java - java并发编程中的 'mutable variable'这个词和函数式编程中的含义一样吗？

java - SDK的1.8和JDK_1.8.0的区别

java - 有什么方法可以基于自由运行、独立于系统时钟的时钟来停放线程吗？

java - Lambda 重载方法

scala - 不可变集合的真正优势是什么？

java - 在 Scala 的案例类和类字段中使用 Optional 是否有代码味道？