scala - Scala 中 Await.result 和 futures.onComplete 的区别

Question

我正在使用以下两个代码片段在多线程中执行代码。但我的行为有所不同。

片段 1:

val futures = Future.sequence(Seq(f1, f2, f3, f4, f5))
futures.onComplete{
  case Success(value) =>
  case Failure(value) =>
}

片段 2:

Await.result(Future.sequence(Seq(f1, f2, f3, f4, f5)), Duration(500, TimeUnit.SECONDS))

在 futures 中，我只是设置一些属性并检索结果。

注意:只知道上面两个代码片段之间的行为差​​异就足够了。

Answer 1

onComplete 在 ExecutionContext 中的某个任意(未指定)线程上运行，而 Await.result 在当前线程上运行，并阻止它直到它完成或超过指定的超时。第一个是非阻塞的，第二个是阻塞的。

这两个代码片段在处理失败的方式上也存在差异，但从代码中可以明显看出这一点。