8

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

4

2 回答 2

15

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

阿卡

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
于 2011-04-13T10:43:57.997 回答
1

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

于 2011-04-13T09:18:53.493 回答