码头运营是否关闭了河流？

Question

diPath包含200k个文件，我想一个一个地读取它们并做一些处理。下面的代码片段导致java.nio.file.FileSystemException：diPath/file-N打开的文件太多。终端操作foreach（）不是应该在移动到下一个之前关闭打开的流（即打开的文件）吗？换句话说，我必须为流式文件添加try-with-资源吗？

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

Answer 1

匿名用户

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

代码

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 -> {  });

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

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

所以这是首选的解决方案。或者，为了使其完全正确：

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

Answer 2

NoforEach不会关闭流（由文件列表或文件行创建）。它被记录在javadoc中，例如文件。列表：

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