awaitAll ne fonctionne pas dans mon test

Question

Lorsque je crée un avenir ad-hoc et l'appeler cela fonctionne bien.

 
scala> val f = future {Thread.sleep(1000 * 60 * 1); println("Hi"); 20} 
f: scala.actors.Future[Int] = 

scala> f() 
Hi 
res39: Int = 20 

Lorsque je crée le même futur et appelle awaitAll cela ne fonctionne pas. Le awaitAll renvoie None comme si le futur n'était pas résolu.

 
scala> val f = future {Thread.sleep(1000 * 60 * 1); println("Hi"); 20} 
f: scala.actors.Future[Int] = 

scala> awaitAll(1000 * 60 * 2, f) 
Hi 
res40: List[Option[Any]] = List(None) 

Answer 1

préfère le future sur Future qui est dépréciée.

Que diriez-vous: « Préférez le Future de l'avenir scala.concurrent au Future du passé dans scala.actors, qui est dépréciée. »

Comme d'habitude, Heather Miller le dit le mieux; voir le commentaire.

object Test extends App { 
    import scala.concurrent._ 
    import Await._ 
    import Future._ 
    import duration._ 
    import ExecutionContext.Implicits.global 

    val data = List(1,2,3) 
    result(traverse(data)(i => future{10 * i}), Duration("10 sec")) foreach println 
} 

Answer 2

J'espère vous aider.

import scala.actors._ 

object StackOverFlow13331294 extends App { 
    Futures awaitAll (1000 * 60 * 1, 
      Seq(new StackOverFlow13331294 !! "execute"): _*) foreach println 
} 

class StackOverFlow13331294 extends Actor { 
    start 
    override def act = react { 
     case "execute" => 
      // Thread sleep 1000 * 60 * 1 ? 
      println("Hi") 
      reply("20") 
    } 
}