Блог

Когда я жду результата 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
  

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