平面图期货列表的期货正在执行阻塞操作，那么为什么不将代码包含在阻塞{...}中呢？

Question

在完成Coursera课程中关于反应式编程的一些练习和视频时，我看到了一个方法的定义，该方法可以“排序”未来的列表。该方法返回一个未来，它将完成等待fts中所有期货的工作（见下面的代码），并将这些结果打包到一个列表[T]，当按顺序返回的将来[List[T]完成时，该列表将可用。

def sequence[T](fts: List[Future[T]]): Future[List[T]] = {
    fts match {
        case Nil => Future(Nil)
        case (ft::fts) => ft.flatMap(t => sequence(fts)
            .flatMap(ts => Future(t::ts)))
    }
}

这个代码是老师给的，所以我猜它应该代表了如何做这种事情的最佳模式。然而，在讲座的其他地方，老师们说：

每当有长时间运行的计算或阻塞时，请确保在阻塞构造中运行它。例如：

    blocking {
      Thread.sleep(1000)
    } 

用于将一段代码指定为潜在的阻塞。具有阻塞构造的异步计算通常被调度在单独的线程中以避免潜在的死锁。例如：假设您有一个未来f，它等待计时器或资源或监视器条件，该条件只能由其他未来g满足。在这种情况下，f中执行等待的代码部分应该包装在阻塞中，否则未来g可能永远不会运行。

现在…我不明白的是为什么“匹配”表达式没有包装在“阻塞”表达式中。难道我们不希望所有的平面映射都（潜在地）花费大量的时间吗？

附注：scala.concurrent.Future 类中有一个“官方”序列方法，该实现也不使用阻塞。

我也会把它发布到Coursera论坛，如果我得到回复，我也会在这里发布。




Answer 1

匿名用户

难道我们不期望所有的平面图都需要（潜在的）相当长的时间吗？

不。flatMap只是构建了一个新的未来，并立即返回。它不会阻塞。

请参阅平面图的默认实现。这是它的简化版本：

trait Future[+T] {

  def flatMap[S](f: T => Future[S])
                (implicit executor: ExecutionContext): Future[S] = {

    val promise = new Promise[S]()

    this.onComplete {

      // The first Future (this) failed
      case Failure(t) => promise.failure(t)

      case Success(v1) =>

        // Apply the flatMap function (f) to the first Future's result
        Try(f(v1)) match {

          // The flatMap function (f) threw an exception
          case Failure(t) => promise.failure(t)

          case Success(future2) =>
            future2.onComplete {

              // The second Future failed
              case Failure(t) => promise.failure(t)

              // Both futures succeeded - Complete the promise
              // successfully with the second Future's result.
              case Success(v2) => promise.success(v2)
            }
        }
    }
    promise.future
  }
}

当您调用（平面图）时发生的事情的概述：

< li >创建promise < li >向此未来添加回拨 < li >兑现promise

该方法返回一个< code>Future，它将完成等待所有未来的工作

我认为这种描述有些误导。您从Future.sequence中获得的Future并不真正“工作”。正如您在上面的代码中看到的，您从平面图中获得的Future（因此您从Future.sequence中获得的Future）只是一个最终将由其他东西完成的promise。唯一真正做任何事情的是执行上下文；Future只是指定要做什么。