终端操作是否关闭流？

Question

dirPath 包含 200k 个文件。我想一一阅读并做一些处理。以下 sn-p 导致java.nio.file.FileSystemException: dirPath/file-N Too many open files。终端操作forEach() 不应该在移动到下一个之前关闭打开的流（即打开的文件）吗？换句话说，我是否必须为流文件添加 try-with-resources？

Files.list(dirPath)
     .forEach(filePath -> {
              Files.lines(filePath).forEach() { ... }
              });

Answer 1

No forEach 不会关闭流（由Files.list 或Files.lines 创建）。它记录在 javadoc 中，例如 Files.list:

返回的流封装了一个 Reader。如果需要及时处理文件系统资源，则应使用 try-with-resources 构造来确保在流操作完成后调用流的 close 方法。

Answer 2

在大多数情况下，嵌套的 forEach 是错误的工具。

代码

Files.list(dirPath).forEach(filePath -> Files.lines(filePath).forEach(line -> { ... });

可以并且应该替换为

Files.list(dirPath).flatMap(filePath -> Files.lines(filePath)).forEach(line -> { ... });

或者好吧，因为在这种情况下并不那么容易：

Files.list(dirPath).flatMap(filePath -> {
    try { return Files.lines(filePath);}
    catch(IOException ex) { throw new UncheckedIOException(ex); }
}).forEach(line -> {  });

作为副作用，您可以免费获得以下内容：

Stream.flatMap(…):

每个映射的流在其内容放入该流后关闭。

所以这是首选的解决方案。或者好吧，让它完全正确：

try(Stream<Path> dirStream = Files.list(dirPath)) {
    dirStream.flatMap(filePath -> {
        try { return Files.lines(filePath);}
        catch(IOException ex) { throw new UncheckedIOException(ex); }
    }).forEach(line -> { });
}