如何在Scala中的一组Actors中检索第一个完成的Actor？

发布时间：2020-12-16 08:47:03 所属栏目：安全来源：网络整理

导读：我有一定数量的长期运行的Actors,我希望编写一个同步函数,它返回完成的第一个.我可以通过旋转等待期货来做到这一点(例如： while (! fs.exists(f = f.isSet) ) { Thread.sleep(100)}val completeds = fs.filter(f = f.isSet)completeds.head() ),但这似乎非

我有一定数量的长期运行的Actors,我希望编写一个同步函数,它返回完成的第一个.我可以通过旋转等待期货来做到这一点(例如：

while (! fs.exists(f => f.isSet) ) {
  Thread.sleep(100)
}
val completeds = fs.filter(f => f.isSet)
completeds.head()

),但这似乎非常“非演员-y”

scala.actors.Futures类有两个方法awaitAll()和awaitEither()看起来非常接近;如果有awaitAny()我会跳上它.我错过了一个简单的方法来做到这一点,还是有一个适用的共同模式？

解决方法

等待完成的更“玩乐”的方式是创建一个负责处理完成结果的actor(让我们称之为ResultHandler)

工作人员不是回复,而是以“一劳永逸”的方式向ResultHandler发送答案.后者将继续处理结果,而其他工人完成他们的工作.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!