Sử dụng tương lai và Thread.sleep

Question

Bằng cách thực thi mã scala này, tôi không có bất kỳ đầu ra nào trong bảng điều khiển. (Tôi thực sự không hiểu điều gì đang xảy ra)

Nếu tôi xóa Console.println("Console.println OK!") => mọi thứ có vẻ ổn.

Nếu tôi xóa Thread.sleep(2000) => mọi thứ có vẻ ổn.

Bạn có bất kỳ ý tưởng nào về điều này không? Cảm ơn nhiều!

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

chờ đợi của bạn đang chờ đợi tương lai để hoàn thành, mà được thực hiện sau 2 giây, nhưng nó không chờ onSuccess xử lý, mà thực hiện trong một thread (tương tự như trong tương lai), nhưng sau Await.ready(f, 60 seconds), do đó, quá trình thoát sớm hơn bạn in một cái gì đó. Để xử lý nó một cách chính xác - tạo ra tương lai mới cho 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") 

Kết quả cho Await.ready(f, ...):

exit 
OK! 
OK! 

Kết quả cho Await.ready(f2, ...):

OK! 
OK! 
exit 

Answer 2

Chỉ cần đặt readLine() trong mã của bạn.