我实现了一个简单的作业处理器来处理期货中的子作业(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)
}
}
}
Run Code Online (Sandbox Code Playgroud)
顶级的结果是JobResults的递归列表列表... 我递归搜索List以查找失败的结果,然后根据结果类型返回错误或组合结果.这是有效的,但我想知道是否有一个更优雅/更容易的解决方案来处理未来的例外?