等待Scala Future阻塞线程吗？

发布时间：2020-12-16 08:48:47 所属栏目：安全来源：网络整理

导读：当我等待 Scala Future的结果时,它是否更像接收,或者像是反应,即它是否阻塞了一个线程,或者在结果可用之后安排继续？解决方法是的,在stdlib中它会阻塞线程,并同步等待结果.如果你想将延续传递方式应用于期货,你必须使用Akka或Scalaz,它们允许直接在方框中

当我等待 Scala Future的结果时,它是否更像接收,或者像是反应,即它是否阻塞了一个线程,或者在结果可用之后安排继续？

解决方法

是的,在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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!