热门
最新
红包
立Flag
投票
同城
我的
发布
【AKKA】非阻塞方式获取Future的值
我们可以使用Future.onComplete() 回调来实现非阻塞的通知：
println("\nStep 2: Non blocking future result")
import scala.util.{Failure, Success}
donutStock("vanilla donut").onComplete {
case Success(stock) => println(s"Stock for vanilla donut = $stock")
case Failure(e) => println(s"Failed to find vanilla donut stock, exception = $e")
}
Thread.sleep(3000)
————————————————
版权声明：本文为CSDN博主「flydean程序那些事」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/superfjj/article/details/103870574
CSDN App 扫码分享
评论
点赞
打赏
- 复制链接
- 举报
下一条：
【AKKA】阻塞方式获取Future的值 println("\nStep 2: Call method which returns a Future") import scala.concurrent.Await import scala.concurrent.duration._ val vanillaDonutStock = Await.result(donutStock("vanilla donut"), 5 seconds) println(s"Stock of vanilla donut = $vanillaDonutStock")————————————————版权声明：本文为CSDN博主「flydean程序那些事」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。原文链接：https://blog.csdn.net/superfjj/article/details/103870574
