Quando aspetto per risultato di Scala futuro, non si comporta più come ricevono, o come reagire, cioè fa bloccare un filo, o programmi una continuazione dopo risultato se disponibile?Aspetta il thread di blocco di Scala Futuro?
7
A
risposta
15
Sì, in stdlib blocca il thread e attende i risultati in modo sincrono. Se vuoi applicare lo stile di passaggio continuo ai futures, dovresti usare Akka o Scalaz che consentono di aggiungere ganci sul completamento dei futures direttamente dalla scatola.
Akka:
val f1 = Future { Thread.sleep(1000); "Hello" + "World" }
val f2 = f1 map { _.length }
f2 foreach println //Done asynchronously and non-blocking
Stessa cosa con Scalaz:
scala> val f1 = promise {Thread.sleep(1000); "Hello" + "World"}
f1: scalaz.concurrent.Promise[java.lang.String] = [email protected]
scala> val f2 = f1 map{str => str.length}
f2: scalaz.concurrent.Promise[Int] = [email protected]
scala> f2.map(println)
10
res5: scalaz.concurrent.Promise[Unit] = [email protected]
1
Dovrebbe bloccare il thread corrente, ma se il thread di lavoro è bloccato, dipende.