如何解决如何在JVM关闭时允许/等待Akka流完成?
基本上,我的目标是在重新启动正在处理一堆Akka流的服务器时,关闭挂钩应等待所有流完成,然后终止ActorSystem
。
我定义了一个关闭方法,该方法可以终止actor系统,就像这样-
def close(): Future[Terminated] = {
logger.info("Terminating actor system")
system.terminate()
}
但是,这显然不是等待流完成,而是只是中止正在运行的流并终止actor,这不能解决我正在尝试做的事情。因此,这似乎不正确。
我还通读了参与者支持其自身的关闭挂钩的文档,但是如何配置它们以使流运行到完成,然后才允许JVM退出?
解决方法
我们为此使用killswitch:它允许关闭actor流。您仍然需要等待所有流完成,killswitch才启动适当的流关闭。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。