Как разрешить список фьючерсов в Scala

Question

У меня есть вызов, который возвращает будущее. Тем не менее, мне нужно сделать n звонков, поэтому я вернусь к n фьючерсам. Мне интересно, как я хотел бы получить фьючерсы на все решимостью, прежде чем продолжить (без блокировки сервера)

Например,

while(counter < numCalls){ 
    val future = call(counter) 
    future.map{ x => 
     //do stuff 
    } 
    counter += 1 
} 

//Now I want to execute code here after ALL the futures are resolved without 
//blocking the server 

Answer 1

Вы можете использовать Future.sequence(futureList) для преобразования List[Future[X]] в Future[List[X]]. А так как последнее просто просто Future, вы можете дождаться его завершения с помощью Await.ready или аналогичных помощников.

Таким образом, вам нужно будет сохранить список фьючерсов, которые вы создаете. Что-то вроде:

val futures = new ListBuffer[Future[X]] 
while(counter < numCalls) { 
    val future = call(counter) 
    futures += future 
    future.map { x => 
     //do stuff 
    } 
    counter += 1 
} 
val f = Future.sequence(futures.toList) 
Await.ready(f, Duration.Inf) 

, которые можно было бы написать как:

val futures = (1 to numCalls).map(counter => { 
    f = call(counter) 
    f.map(x => ...) 
    f 
}) 
Await.ready(Future.sequence(futures), Duration.Inf) 

Answer 2

Чуть более функциональны:

val futures = for { 
    c <- 0 until 10 
    } yield { 
    val f = call(c) 
    f onSuccess { 
     case x => 
     // Do your future stuff with x 
    } 
    f 
    } 
Future.sequence(futures) 

Answer 3

я понимаю, что вы хотите сделать что-то после того, как фьючерсы закончены ,например. обратный вызов, без блокировки исходного вызова? Тогда вы должны сделать что-то вроде этого:

val futures = for (...) yield { 
    future { 
    ... 
    } 
} 

val f = Future sequence futures.toList 

f onComplete { 
    case Success(results) => for (result <- results) doSomething(result) 
    case Failure(t) => println("An error has occured: " + t.getMessage) 
} 

http://docs.scala-lang.org/overviews/core/futures.html

Таким образом, вы не блокируете с вызовом ЖДЕТ, но вы все еще ждете всех фьючерсы, чтобы закончить, а затем сделать что-то по всем результатам. Ключевыми аспектами является использование Future.sequence, чтобы объединить много фьючерсов вместе, а затем использовать обратный вызов, чтобы действовать на результат.