Java 8平面映射流在try with resources块中关闭[重复]

Question

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

    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

现在我意识到在尝试资源块中使用流并不常见。但在我的真实代码中，我使用Stream

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

上面的代码只是一个例子来说明这个问题。

我的问题是为什么我的流被关闭了，尽管我使用map和平面地图来返回一个新流。我是否错误地期望这两个方法返回新的Stream实例，因此只有myStream被关闭，而不是从map操作返回的那个？我对单子有一个模糊的理解，但是map和平面地图方法的行为意味着Stream不是一个真正的单子？




Answer 1

一旦try块完成，流将被关闭。

因为流

为什么我在块中创建的流实例也被关闭

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

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...");
};