Использование фьючерсов и Thread.sleep

Question

Выполняя этот код scala, у меня нет вывода в консоли. (Я действительно не понимаю, что происходит)

Если я удалю Console.println("Console.println OK!") => все кажется прекрасным.

Если я удалю Thread.sleep(2000) => все кажется прекрасным.

У вас есть идеи по этому вопросу? Большое спасибо!

Клеман

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

Ваш Await ждет будущего завершения, что делается через 2 секунды, но он не ждет onSuccess обработчика, который выполняет в другом потоке (по аналогии с будущим), но после Await.ready(f, 60 seconds), поэтому процесс выходит раньше, чем вы что-то печатаете. Для того, чтобы правильно обработать его - создать новое будущее для 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") 

Результаты для Await.ready(f, ...):

exit 
OK! 
OK! 

Результаты для Await.ready(f2, ...):

OK! 
OK! 
exit 

Answer 2

Просто положить ReadLine() в коде.