将承诺链接到另一个

Question

我正在阅读 scala.concurrent.impl.Promise 并且对“将 DefaultPromise 与另一个链接”的概念感到困惑。我了解“防止内存泄漏”部分，但不知道如何编写DefaultPromise 的当前状态为DefaultPromise 的示例。

当DefaultPromise 首次创建时，它的状态是Nil，并且随着我们不断向其附加flatMap，列表会不断增长。什么情况下是分支

case dp: DefaultPromise[_] => dp.asInstanceOf[DefaultPromise[S]].linkRootOf(p)

在Future.flatMap 中调用？

  test("default promise linking") {
    //f1.getState === Nil
    val f1 = Future {Thread.sleep(200000); 2}

    //f1.getState === List(CallbackRunner1)
    f1.flatMap(x => Future {Thread.sleep(200000); 4})
    //f1.getState === List(CallbackRunner2, CallbackRunner1)
    f1.flatMap(y => Future {Thread.sleep(200000); 3})

    Thread.sleep(30000000)
  }

Answer 1

举个例子：

val f1 = Future {Thread.sleep(200000); 2}
val f2 = f1.flatMap(x => {
    val f3 = Future {Thread.sleep(200000); 4}
    f3
})

f1 和 f3 当然不会共享相同的状态 - 一个用 2 解析，另一个用 4 解析。但是当 f1 完成时，处理程序 (f(v)) 将创建 f3 并且它将匹配您感到困惑的 the case。然后，f2（p in flatMap）将链接到f3，以便它们共享相同的状态。