【问题标题】:Does a wait on Scala Future block thread?是否等待 Scala Future 阻塞线程?
【发布时间】:2011-08-04 13:11:31
【问题描述】:

当我wait等待 Scala Future 的结果时,它的行为是更像 receive,还是像 react,即它是否阻塞了一个线程,或在结果可用时安排继续?

【问题讨论】:

    标签: scala actor future promise


    【解决方案1】:

    是的,在 stdlib 中它会阻塞线程,并同步等待结果。如果您想将延续传递样式应用于期货,则必须使用 Akka 或 Scalaz,它们允许直接从框中添加期货完成的钩子。

    Akka:

    val f1 = Future { Thread.sleep(1000); "Hello" + "World" }
    
    val f2 = f1 map { _.length }
    
    f2 foreach println //Done asynchronously and non-blocking
    

    Scalaz相同:

    scala> val f1 = promise {Thread.sleep(1000); "Hello" + "World"}
    f1: scalaz.concurrent.Promise[java.lang.String] = scalaz.concurrent.Promise$$anon$1@1f7480
    
    scala> val f2 = f1 map{str => str.length}
    f2: scalaz.concurrent.Promise[Int] = scalaz.concurrent.Promise$$anon$1@1d40442
    
    scala> f2.map(println)
    10
    res5: scalaz.concurrent.Promise[Unit] = scalaz.concurrent.Promise$$anon$1@116ad20
    

    【讨论】:

      【解决方案2】:

      它应该阻塞当前线程,但工作线程是否阻塞,取决于。

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 2016-06-11
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2017-08-20
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多