拋出未來的異常

Question

我需要在程序中拋出一個異常，但異常在未來發生，所以拋出在不同的線程中。如何使這個例子工作？

object TestFutures extends App { 

    val f0 = Future { 0 } 
    val f1 = Future { 1 } 
    val fx = Seq(f0,f1) 

    fx.map { 
    seq => seq.map { i => 
     println("i="+i) 
     if (i == 1) 
       throw new Exception("This is an exception") 

    } 
    } 


    Thread.sleep(5000) 
} 

這是程序的輸出，但我需要它拋出異常：

i=0 
i=1 

Answer 1

結果仍是未來

val stillFutures: Seq[Future[Unit]] = fx.map { 
    seq => seq.map { i => 
     println("i="+i) 
     if (i == 1) 
     throw new Exception("This is an exception") 

    } 
    } 

您可以在成功/失敗檢查每個未來

stillFutures.foreach{ 
_.onComplete{ 
    case Success(_) => // do nothing 
    case Failure(ex) => throw ex 
}} 

Answer 2

如何使這個例子工作？

您可以使用for，使其工作作爲

val f0 = Future { 0 } 
val f1 = Future { 1 } 
val fx = Seq(f0,f1) 

for(seq <- fx){ 
    for(i <- seq) { 
    println("i="+i) 
    if (i == 1) { 
     throw new Exception("This is an exception") 
    } 
    } 
} 
Thread.sleep(5000)