scala - 是否等待 Scala Future 阻塞线程?

标签 scala actor future promise

当我等待对于 Scala Future 的结果,它的行为是否更像 接收 , 或喜欢 react ,即它是否阻塞线程,或者在结果之后安排延续(如果可用)?

最佳答案

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

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

关于scala - 是否等待 Scala Future 阻塞线程?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5646879/

相关文章:

scala - Akka actor并发问题

rust - Rust 参与者框架 Actix 是否保证两个参与者之间的消息顺序?

c# - C# 中的 Promise 等价物

jQuery 验证规则 addMethod 中的信用卡到期日限制 future 20 年

java - Eclipse 说 Java 类无法解析导入的 scala 类型

Scala Else 返回函数

scala - 如何提高基于 String 或 Double 的值的类型安全性?

scala - 使用 Scala Cats 将函数列表应用于值

scala - 辛格尔顿斯卡拉 Actor ?

java - Future 的 ConcurrentHashMap 和双重检查锁定