是否有可能制作一个Actor
等待 X 秒来接收任何消息,如果收到消息,则照常处理它,否则将消息发送给其他人Actor
(在构造函数中预先确定)?
有可能,看看Akka Actor“询问”和“等待”带有 TimeoutException https://stackoverflow.com/questions/10095927。但请记住,在 Actor 内部阻塞是一个非常糟糕的主意,因为在此期间 Actor 无法处理任何其他消息。此外,它还会阻塞一个 Akka 处理线程。
更好的方法是发送消息(即发即忘)并使用安排一些超时事件Akka调度器 http://doc.akka.io/docs/akka/snapshot/java/scheduler.html。当响应到达时,取消该事件或设置一些标志,以便在答复确实按时到达时不会触发该事件。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)