8

Scala Futureの結果を待つとき、それは受信のように、または反応のように動作しますか?つまり、スレッドをブロックしますか、または可能な場合は結果の後に継続をスケジュールしますか?

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 に答える