未来回调方法和promise[成功和失败]之间的区别？

Question

我正在使用Future和Promises学习Scala并发。

我不明白，使用< code >回调方法完成未来和使用promise之间的确切区别是什么？

这是否意味着未来回调方法实际上没有完成未来？只有使用promise，我们才能完成未来？

还有，我见过很多像你这样的地方，既可以阅读期货，也可以阅读无极，但你只能写信给无极。

Answer 1

您实际上并没有完成< code>Future，您只是在完成时将回调传递给trigger。您可以使用< code>Promise来控制何时触发回拨。scala官方文档示例:

val p = Promise[T]()
val f = p.future

val producer = Future {
  val r = produceSomething()
  p success r
  continueDoingSomethingUnrelated()
}

顺便说一句，未来在引擎盖下使用promise。

Answer 2

你不能< code >完成一个< code >未来。

未来应该是一个计算，这个计算（一旦开始）当它开始时就完成了。创建后，您无法控制它。您可以为其分配 onComplete 回调，该回调将在此将来完成时触发，但您无法控制何时会触发。

如果你想拥有一个你可以控制完成的Future，你可以像政治家一样PromisethatFuture。现在你是成功还是失败地完成那个未来取决于你。

// lets promise an Int
val promise = Promise[Int]()

// Now... we also have a future associated with this promise
val future = promise.Future

// assign a callback which will be called when future completes
future.onComplete(
  case Success(i) => println("Future complete :: " + i)
  case Failure(ex) => println("Future failed :: " + ex.toString)
)

// Future by itself provides you no way to complete it

// if you want to complete this future, you can fulfil your promise
promise.complete(Try(10))

Answer 3

期货仅在异步计算结束时完成：

val f: Future[List[Int]] = Future {
  makeSomeNumbers() //when this finishes, the Future is completed.
}

f onSuccess {
  case foo => println("I was completed when makeSomeNumbers finished")
}

而promise可以创造一个可以人工完成的未来。

val p = Promise[String]()
val f = p.future

p success('hi') //when success is called, the Future is completed.

f onSuccess {
  case foo => println("I was completed because a Promise told me to do so")
}

传递给< code>onSuccess的回调并不完成未来，它只在未来完成时监听并做一些事情。在promise的情况下，您可以调用它的< code>success方法来完成其关联的未来。