嵌套期貨在玩動作

進出口使用播放和擁有，我想要做的兩件事情的操作： -嵌套期貨在玩動作

首先檢查我的緩存值
其次，調用與價值的網絡服務

由於WS API返回Future，我使用的是Action.async。
我的Redis緩存模塊還返回Future。

假設我對可能長時間運行的任務適當地使用了另一個ExecutionContext。

問：有人可以通過以下步驟確認我是否在正確的軌道上。我知道我沒有滿足以下例外情況 - 只是爲了簡潔而保持簡單。

def token = Action.async { implicit request => 


    // 1. Get Future for read on cache 

    val cacheFuture = scala.concurrent.Future { 
     cache.get[String](id)  
    } 


    // 2. Map inside cache Future to call web service 

    cacheFuture.map { result => 

     WS.url(url).withQueryString("id" -> result).get().map { response => 
      // process response 
      Ok(responseData) 
     } 

    } 

}

我擔心的是，這可能不是做事情的最有效的方式，因爲我認爲不同的線程可以處理完成每一個期貨的任務。

任何建議更好的方法，不勝感激。

來源

2016-02-25 JamieP

這不是特定於Play的。我建議你看一下文檔解釋Future的工作原理。

val x: Future[FutureOp2ResType] = futureOp1(???).flatMap { res1 => futureOp2(res1, ???) }

或者與-理解

val x: Future[TypeOfRes] = for { 
    res1 <- futureOp1(???) 
    res2 <- futureOp2(res1, ???) 
    // ... 
} yield res

對於Future s的執行方式（使用線程），這取決於其ExecutionContext使用（例如全球性的遊戲之一。 ..）。

WS.get返回Future，它不應該被內cacheFuture.map叫，否則會返回一個Future[Future[...]]。

來源

2016-02-25 16:33:29 cchantep

好cchantep感謝您的意見。如果能夠幫助解決我的問題，我會在文檔中進一步挖掘並回來。 – JamieP

嵌套期貨在玩動作

回答

相關問題