假设我需要运行一些并发任务.
我可以将每个任务包装在Future中并等待它们完成.或者,我可以为每个任务创建一个Actor.每个Actor将执行其任务(例如,在接收到“开始”消息时)并将结果发回.
解决方法
因为它在语法上更简单.
val tasks: Seq[() => T] = ???
val futures = tasks map {
t => future { t() }
}
val results: Future[Seq[T]] = Future.sequence(futures)
结果未来您可以等待使用Await.result,或者您可以进一步映射/在for-comprehension中使用它或在其上安装回调.
相比之下,实例化所有演员,向他们发送消息,编码他们的接收块,接收他们的响应并关闭它们 – 这通常需要更多的样板.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
