Scala Futuresの任意の数のリストの順次実行

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) } 
    } 

、高次将来の機能をCOMPOSE方法とを生成パラメータ。このメソッドはすべての高次関数を繰り返し、完全な新しい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)) 
    } 
} 

将来を返す関数のリストを提供することができれば、これは必要なものです。 List[Future[_]]の問題は、すでに開始されているため、実行に関して連鎖できないことです。あなたは単一のスレッドExecutionContextを提供します。

障害が発生した場合、最初の失敗を返し、他の先物の実行を停止します。