Java 8中flatMap打开的流遇异常时如何正确关闭？

咱们先结合你给出的代码和Javadoc说明，逐个拆解不同异常场景下的流关闭情况：

一、Files.list抛出异常的场景 #

• 首次调用Files.list就抛出IOException：这种情况下，Files.list(dir)根本没成功生成Stream实例，不存在任何打开的流，自然不需要关闭操作。
• 后续调用Files.list抛出异常：此时之前已经处理过的Files.list返回的流，已经被flatMap按照Javadoc要求处理完毕——它们的内容已经被合并到当前流中，所以已经被自动关闭，不会有资源泄漏风险。

二、filter抛出异常的场景 #

这是你最关心的核心场景，咱们重点梳理：
首先明确两个关键前提：

1. paths.stream()是基于普通List生成的流，它没有绑定任何需要手动释放的底层资源（比如文件句柄），所以无论是否出现异常，都不需要手动关闭它，也不存在资源泄漏问题。
2. 需要重点关注的是当前正在被flatMap处理的那个Files.list返回的Stream——因为这个流关联了文件系统的遍历资源，必须确保它被正确关闭。

根据Java Stream的实现规范，flatMap操作会全权管理它生成的每个映射流的生命周期：哪怕处理过程中因为下游操作（比如你代码里的filter）抛出异常而中断，flatMap也会保证当前正在处理的那个映射流被立即关闭。也就是说，当filter(this::mightThrowException)抛出异常时，flatMap会自动关闭当前正在遍历的Files.list流，不会让文件资源泄漏。

举个更直白的例子：假设我们正在处理第一个目录对应的Files.list流，遍历到某个Path时filter抛出了异常，那么这个Files.list流会被flatMap自动关闭；而之前已经处理完成的目录对应的流早就已经被关闭了，paths.stream()本身也不需要额外处理。

额外补充 #

为什么Files.list返回的流需要手动关闭？因为它背后绑定了文件系统的目录遍历资源，而普通集合生成的流没有这类绑定资源，所以不需要关闭。flatMap的设计已经考虑到了这种需要关闭的流的场景，无论是正常完成遍历还是异常中断，都会正确清理每个映射出来的流资源。

内容的提问来源于stack exchange，提问作者Étienne Miret