如何处理Scala期货中的异常?
发布时间:2020-12-16 09:05:14 所属栏目:安全 来源:网络整理
导读:我实现了一个简单的作业处理器来处理期货中的子作业( scala.actors.Futures).这些期货本身可以为加工子工作创造更多的未来.现在,如果其中一个子工具抛出异常,我希望作业处理器回复该作业的错误消息.我有一个解决方法来发现失败的subjobs,但我不确定这是否是
我实现了一个简单的作业处理器来处理期货中的子作业(
scala.actors.Futures).这些期货本身可以为加工子工作创造更多的未来.现在,如果其中一个子工具抛出异常,我希望作业处理器回复该作业的错误消息.我有一个解决方法来发现失败的subjobs,但我不确定这是否是最好的解决方案.基本上它的工作原理如下:
sealed trait JobResult case class SuccessResult(content: String) extends JobResult case class FailedResult(message: String) extends JobResult for(subjob <- subjobs) yield { future { try { SuccessResult(process(subjob)) } catch { case e:Exception => FailedResult(e.getMessage) } } } 顶级的结果是JobResults的递归列表列表…我递归搜索List以查找失败的结果,然后根据结果类型返回错误或组合结果. 解决方法
你现在这样做的方式,实质上就是scala.Either的设计目的.见
http://www.scala-lang.org/api/current/scala/Either.html
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |