0

我有以下测试代码片段：

import scala.concurrent.{Await, Future}
import scala.concurrent.duration.Duration
import scala.util.Success

import scala.concurrent.ExecutionContext.Implicits.global

object FutureAndThen extends App {

  val future = Future {
    println("Started initial Future")
    10
  } andThen { case Success(value) =>
    println("Started callback")
    Thread.sleep(5000)
    println(s"Finished callback: value = $value")
  } map { x =>
    println("Chained transformation")
    x * 2
  }

  println(Await.result(future, Duration.Inf))

}

它产生以下输出：

Started initial Future
Started callback
Finished callback: value = 10
Chained transformation
20

我希望andThen回调异步执行。但实际的执行是下一个：

  1. 执行原来的未来
  2. 执行异步回调
  3. 运行转换 ( map)

起初我认为问题在于ExecutionContext决定在单线程中运行所有这些操作。我将其更改为使用 custom ExecutionContext：

implicit val ctx = ExecutionContext.fromExecutor(
  (command: Runnable) => new Thread(command).start()
)

结果是一样的。你能告诉我我错过了什么吗？

4

1 回答 1

3

这种行为实际上记录在Future.andThen：

对这个未来的结果应用副作用函数，并用这个未来的结果返回一个新的未来。

此方法允许强制以指定的顺序执行回调。

这意味着map在内部计算完成之前不会开始工作andThen。如果这不是你想要的，你必须调用map原来的Future. 然后你可以使用onComplete而不是andThen，所以代码会变成这样：

  val future = Future {
    println("Started initial Future")
    10
  }

  future onComplete { case Success(value) =>
    println("Started callback")
    Thread.sleep(2000)
    println(s"Finished callback: value = $value")
  }

  val f2 = future map { x =>
    println("Chained transformation")
    x * 2
  }

  println(Await.result(f2, Duration.Inf))

PS AFAIK 没有onComplete可用于方法链接的标准等效项，我认为这是设计使然，通过阅读代码更容易预测行为。目前您可以使用一个简单的规则：如果它被链接 - 它稍后执行。

于 2017-12-20T17:44:51.867 回答