另一个 scala Futures 组合谜题

Question

我正在将代码从同步样式迁移到异步样式。问题相当简单：调用一系列函数，并在第一个函数处停止以返回非错误结果（返回该值，否则返回最后一个计算值）。我开始了：

def find(fs: Seq[Function0[Int]], result: Int = -1): Int = {
  if (fs.isEmpty) result
  else {
    val res = fs.head()
    if (res != 0) res
    else find(fs.tail, res)
  }
}

但是，如果函数变得异步，（即返回 Future[Int]）我无法获得正确的调用。例如，

def ffind(ffs: Seq[Function0[Future[Int]]], result: Future[Int] = Future { -1 }): Future[Int] = {
  if (ffs.isEmpty) result
  else ffind(ffs.tail, ffs.head())
}

效果很好，但它会评估所有函数，而不考虑返回值。但类似：

def findBad(ffs: Seq[Function0[Future[Int]]], result: Future[Int] = Future { -1 }): Future[Int] = {
  if (ffs.isEmpty) result
  else {
      ffs.head() map { res =>
        if (res != 0) res
        else findBad(ffs.tail, Future(res))
      }
   }
}

不进行类型检查。有什么建议么？我们可以假设函数的每次调用都是昂贵的，因此不应该调用两次，也不应该在序列中的第一个“成功”调用之后调用。 TIA

Answer 1

这就是它不进行类型检查的原因：findBad 返回 Future[Int]，但将 res 映射到对 findBad 的调用会导致 Future[Future[Int]]。您需要将map 更改为flatMap。请注意，现在您还需要将第一个条件（如果 res != 0）中的res 也包装成Future，以便两个分支都返回Future。代码如下：

ffs.head() flatMap { res =>
  if (res != 0) Future.succesful(res)
  else findBad(ffs.tail, Future(res))
}

顺便说一句，如果您想全部运行它们并返回先完成的那个，而忽略所有其余部分，那么这是一个有点不同的问题（请参阅here），但是您说每个函数调用都很昂贵，所以我怀疑这就是您正在尝试做。