2011-04-13 8 views

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.