順序執行一個任意數量的斯卡拉期貨的列表

Question

我讀了關於Scala Futures and Promises。

我知道我可以使用回調，flatMap組合或理解連鎖期貨。當未來完成時，另一個未來就開始了，等等。

有沒有辦法鏈接任意數量的期貨的執行，存儲在斯卡拉集合（例如List）？ 我試圖在期貨清單上調用Future.sequence，但它們一起開始並且它們同時執行（而不是順序執行）。

Answer 1

我的回答是更關心如何處理任意數量的斯卡拉期貨函數的列表。

type FUTURE_FUNCTION = String => Future[String] 

    def compose(fs: List[FUTURE_FUNCTION]): FUTURE_FUNCTION = fs match { 
    case List(head) => head 
    case head :: tail => head(_).flatMap { u => compose(tail)(u) } 
    } 

在上面的代碼段中，創建一個撰寫方法和與高階未來功能參數。並且這個方法迭代所有高階函數並組成一個全新的Future函數。

示例使用：

val f1: String => Future[String] = 
    (s: String) => Future { 
     s.toUpperCase 
    } 


    val f2: String => Future[String] = 
    (s: String) => Future { 
     s + " Hello World" 
    } 

    compose(List(f1, f2))("foo bar") 
    > FOO BAR Hello World 

Answer 2

def chainFutures(list: List[() => Future[Any]]): Future[Any] = { 
    list match { 
    case x :: Nil => Future.successful(x) 
    case (x :: xs) => x() flatMap (_ => chainFutures(xs)) 
    } 
} 

這應該做你想做的，如果你可以接受提供返回Future的函數列表。 List[Future[_]]的問題在於它們已經啓動了，所以它們不能被鏈接在執行方面。除了你提供單線程ExecutionContext。

如果發生故障，它將返回第一個故障並停止執行另一個期貨。