Ожидание в Scala Future блокирует поток?

Question

Когда я жду результата Scala Future, он будет вести себя более похоже на получать или как реагировать , т.е. блокирует поток или планируетпродолжение за результатом, если доступно?

Answer 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

То же самое с Скалаз :

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

Answer 2

Он должен блокировать текущий поток, но зависит ли рабочий поток, это зависит.