假设我需要运行一些并发任务.
我可以将每个任务包装在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中使用它或在其上安装回调.
相比之下,实例化所有演员,向他们发送消息,编码他们的接收块,接收他们的响应并关闭它们 – 这通常需要更多的样板.