如何从 scala Future 的输出中检索值？

Question

我正在尝试查询表，将查询的值存储在 Scala 映射中并返回相同的映射。 为此，我想出了以下代码：

def getBounds(incLogIdMap:scala.collection.mutable.Map[String, String]): Future[scala.collection.mutable.Map[String, String]] = Future {
  var boundsMap = scala.collection.mutable.Map[String, String]()
  incLogIdMap.keys.foreach(table => if(!incLogIdMap(table).contains("INVALID")) {
    val minMax    = s"select max(cast(to_char(update_tms,'yyyyddmmhhmmss') as bigint)) maxTms, min(cast(to_char(update_tms,'yyyyddmmhhmmss') as bigint)) minTms from queue.${table} where key_ids in (${incLogIdMap(table)})"
    val boundsDF  = spark.read.format("jdbc").option("url", commonParams.getGpConUrl()).option("dbtable", s"(${minMax}) as ctids")
      .option("user", commonParams.getGpUserName()).option("password", commonParams.getGpPwd()).load()
    val maxTms = boundsDF.select("minTms").head.getLong(0).toString + "," + boundsDF.select("maxTms").head.getLong(0).toString
    boundsMap += (table -> maxTms)
  }
  )
  boundsMap
}

为了从方法getBounds接收值，我使用了方法onCompletion如下：

val tmsobj    = new MinMaxVals(spark, commonParams)
val boundsMap = tmsobj.getBounds(incLogIds)
boundsMap.onComplete({
  case Success(value) =>
  case Failure(value) =>
})

我以前在 Scala 中编写过代码，但我对 Scala 中的Futures 不熟悉。谁能告诉我如何将getBounds返回的值检索到val boundsMap中

Answer 1

您可以使用等待（不是最好的方法）

val boundsMap = Await.result(tmsobj.getBounds(incLogIds),Duration.Inf)

或仅在需要时使用该值

val boundsMap = tmsobj.getBounds(incLogIds)
booundsMap.map(value => Smth_To_Do(value))

Answer 2

不建议从 Future 访问值，因为它违背了异步计算的目的。但是，在某些情况下，您可能正在处理遗留代码，或者在某些情况下从未来获取值是前进的方向。处理这种情况，有两种方法

1. 使用 await 会阻塞线程

Await.result(getBounds, 10 seconds)

所以，这里 await 所做的是，它将等待 10 秒以等待 getBounds 未来完成。如果它在这段时间内完成，那么你就有了价值，否则你会在这里得到一个异常。这种方法最大的缺点就是阻塞了当前的执行线程。

1. 使用回调方法onComplete，就像你使用的那样

getBounds onComplete {
   case Success(someOption) => myMethod(someOption)
       case Failure(t) => println("Error)
     }

所以 onComplete 所做的是注册一个回调函数，该函数将在未来完成时执行。这比等待更安全。 详情可参考Accessing value returned by scala futures。

我希望这能回答您的问题。