使用 futures 和 Thread.sleep

通过执行这个 scala 代码，我在控制台中没有任何输出。 （我真的不明白发生了什么）

如果我删除Console.println("Console.println OK!")=> 一切看起来都很好。

如果我删除Thread.sleep(2000)=> 一切看起来都很好。

您对此有什么想法吗？非常感谢！

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)
  }

}

你的等待正在等待未来完成，这是在2秒后完成的，但它不会等待onSuccesshandler，它在另一个线程中执行（类似于future），但是之后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