在不维护可变状态的情况下释放scala中的IO资源



我需要使用一些Java库,它可能会在一个方法中抛出一些异常,并在另一组方法中返回错误代码。到目前为止,它导致了像这样丑陋的代码

val txn = mgr.prepareTransaction()
val accessRecord = txn.readByQuery(...)
var state : Either[MyError, Result] = null //
try {
  // do something here
  val result = txn.runCodeWithin(new Callable[Result]() {...})
  if (result == -1) {
    state = Left(CanNotReadRecord)
  } else {
    state = Right(txn.getCachedRecord())
  }
} catch {
  case e: Exception => state = Left(GeneralError(e))
} finally {
  state match {
    case Right(_) => txn.commit();
    case _        => txn.rollback();
  }
}

我最感兴趣的是将状态取消为var,并能够在finally块中检查状态。请提供建议。

Scala 2.10引入了Try类,它是对Either[Throwable, Result]用例的功能性更强的替换。它有所有常见的monad操作(使理解工作的东西),以及一些其他有用的方法。(查看此处试用的文档)

以下是您的代码的一个可能的重新实现,使用Try,并用CanNotReadRecordException替换CanNotReadRecord。除了替换之外,它在功能上应该与您的示例等效。

def txResults(txn: Transaction): Try[Record] = for {
    result <- Try{ txn.runCodeWithin(...) }
    checked <- result match {
        case -1 => Failure( new CanNotReadRecordException )
        case _ => Success( txn.getCachedRecord )
    }
} yield checked
txResults(txn) match {
    case Success(record) => txn.commit()
    case Failure(e) => txn.rollback() //and maybe handle `e`
}

Scala ARM(自动资源管理)库以完全气密的方式优雅地处理所有这类事情。

看看吧。

相关内容

  • 没有找到相关文章

最新更新