斯卡拉未来投掷即使它是失败的的onComplete

Question

正在处理的异常为什么下面的代码仍然抛出，即使它正在被onFailure处办理

val f: Future[Int] = Future { 
    Thread.sleep(10) 
    1/0 
    1 
} 

f.onComplete { 
    case Success(value) => println(value) 
    case Failure(ex)=> println(ex) 
} 

Await.result(f, Duration.Inf) // throws an Arithmetic exception 

Answer 1

因为onComplete被注册为回调异常未来，它不会改变它或创造一个新的未来。这意味着你有效地等待将来抛出异常。

你想用recover/recoverWith：

val f: Future[Int] = Future { 
    Thread.sleep(10) 
    1/0 
    1 
} 

val recovered: Future[Int] = f.recover { case e: ArithmeticException => 0 } 
Await.result(recovered, Duration.Inf)