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

2023年6月16日 192次阅读

我有一定数量的长期运行的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发送答案.后者将继续处理结果,而其他工人完成他们的工作.

点赞