| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jonah1347
9年前发布

Scala Async 库

来自: http://colobu.com/2016/02/15/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 特性实现的。

async 用来标记一块异步执行的代码,通常这块代码中包含包含一个或者多个 await 调用。如果没有 await 调用,我们用 future 方法就可以了。

这样,对于复杂的异步代码,你不必使用 map 、 flatMap 或者回调来实现复杂的多层的调用嵌套。

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

比如下面的代码,我们使用纯 future 实现:

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

如果使用 async/await ,代码将得到简化。

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

事实上,这个框架是 SIP-22 - Async 的参考实现。这个Scala特性提议发布于2013年。

</div>

 本文由用户 jonah1347 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!