Scala Async 库

在我以前的文章中，我介绍了 Scala Future and Promise 。 Future 代表一个异步计算，你可以设置你的回调函数或者利用 Await.result 等待获取异步计算的结果,你还可以组合多个 future 为一个新的 future 。 Promise 让你可以控制是否完成计算还是抛出异常，它的 future 方法返回一个 Future 对象， complete 、 success 和 failure 允许你完成计算。如果想要同步操作，可以使用 Await.result 等待 Future 完成或者超时，对于没有实现 Awaitable 的代码块，可以使用 blocking 方法实现同步执行。

以上是对上一篇文章的总结。Scala官方还提供了一个 Async 库，用来简化Scala异步操作，尽管这个库还没有正式加入到Scala的标准库中。它是通过Scala macro 特性实现的。

importExecutionContext.Implicits.global  importscala.async.Async.{async, await}    valfuture = async {  valf1 = async { ...;true}  valf2 = async { ...;42}  if(await(f1)) await(f2)else0  }

比如下面的代码，我们使用纯 future 实现：

val future1 = slowCalcFuture  val future2 = slowCalcFuture  def combined: Future[Int] = for {   r1 <- future1   r2 <- future2  } yield r1 + r2

defcombined: Future[Int] = async {  valfuture1 = slowCalcFuture  valfuture2 = slowCalcFuture   await(future1) + await(future2)  }