在 Scala 中管理可关闭资源移交的最佳方法是什么？

Question

我正在查看 scala-arm 库，由 这个答案，它看起来非常适合在大多数情况下管理资源。

不过，乍一看，它似乎无法处理一个上下文：将一个资源“移交”到另一个资源。在使用 I/O 时，这种情况经常出现：

for (fin <- managed(new FileInputStream(file));
     // almost what we want, except see below
     gzip <- managed(new GZIPInputStream(fin));
     src <- managed(Source.fromInputStream(gzip))) {
  /* some fancy code */
}

现在，问题是这样的：如果 gzip 成功创建，那么 it 负责关闭 fin 和 fin 不应关闭（更新：这不太正确 - 双重关闭很好；请参阅已接受的答案）。但另一种方法是：

for (src <- managed(Source.fromInputStream(
              new GZIPInputStream(new FileInputStream(file))))) {
  /* some fancy code */
}

不太正确 - 如果 GZIPInputStream 构造函数中存在（诚然不太可能）错误，则 FileInputStream 不会关闭。 fromInputStream 也是如此。

scala-arm（或其他一些包）是否提供了我尚未找到的安全处理此清理的工具？

Answer 1

又看了几分钟，发现其实没什么关系。 java.io.Closeable< /a> 规定 close() 对已经关闭的资源是无操作。因此，将所有内容包装在托管中并让它双重关闭是安全的。因此，第一个代码示例是正确的。

Answer 2

对我来说最好的方法是使用迭代器、枚举器和枚举器的概念，这些概念在函数世界中有其基础。

您可能感兴趣的是具有非常好的实现的 Scalaz 库。

换句话说，使用这些概念是为了让源上的迭代器知道消费器何时结束消费，反之亦然。让缺点知道来源没有什么可提供的。

编辑

这是一个非常清楚的帖子< /a> 关于 iteratee 的用途。查看讨论您的问题的动机参数...无论进展顺利或出错，但在正确的时间关闭资源