Korzystanie z futures i Thread.sleep

Question

Wykonując ten kod scala, nie mam żadnych danych wyjściowych w konsoli. (Naprawdę nie rozumiem, co się dzieje)

Jeśli usuniemy Console.println("Console.println OK!") => wszystko wydaje się być w porządku.

Jeśli usuniemy Thread.sleep(2000) => wszystko wydaje się być w porządku.

Czy masz jakieś pomysły na ten temat? Dziękuję Ci bardzo!

Clément

import scala.concurrent.ExecutionContext.Implicits.global 
import scala.concurrent.duration._ 
import scala.concurrent.{Await, Future} 
import scala.language.postfixOps 

object ScalaFuture { 

    def main(args: Array[String]) { 

    val f: Future[String] = Future { 
     Thread.sleep(2000) 
     "future value" 
    } 

    f.onSuccess { 
     case s => { 
     Console.println("Console.println OK!") 
     System.out.println("System.out.println OK!") 
     } 
    } 

    Await.ready(f, 60 seconds) 
    } 

} 

Answer 1

Twój Oczekujcie czeka na przyszłość, aby zakończyć, który odbywa się po 2 sekundach, ale nie czekać na onSuccess obsługi, która wykonuje w innym wątku (podobny do przyszłości), ale po Await.ready(f, 60 seconds), więc proces wychodzi wcześniej, niż coś drukujesz. Aby przetworzyć go poprawnie - stworzyć nową przyszłość dla onComplete:

val f: Future[String] = Future { 
    Thread.sleep(2000) 
    "future value" 
} 

val f2 = f map { s => 
    println("OK!") 
    println("OK!")  
} 

Await.ready(f2, 60 seconds) 
println("exit") 

wyników dla Await.ready(f, ...):

exit 
OK! 
OK! 

wyników dla Await.ready(f2, ...):

OK! 
OK! 
exit 

Answer 2

Wystarczy umieścić readLine() w kodzie.