java - 有没有办法让 akka actor 暂停 X 次

标签 java akka

我们有一个 Akka actor 正在读取一个包含许多文件的大文件夹。

它读取它们以供其他参与者进行处理。

看起来它读取速度太快,最终我们遇到了 OutOfMemoryException

我们想知道是否可以以某种方式暂停/ sleep X 次?

最佳答案

您可以自己暂停它,我的意思是您应该让参与者停止处理文件并设置一个计时器,在 X 秒/分钟后向自己发送恢复消息。

但是...你永远找不到合适的时间(上面的X),它总是太长或太短。出现这种问题是为什么 akka-stream存在。我建议您看一下它,因为它是解决此类问题的唯一好的解决方案。

关于java - 有没有办法让 akka actor 暂停 X 次,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49760021/

相关文章:

Java成员初始化

java - 什么是NullPointerException,我该如何解决?

scala - Source.combine 不接受可变参数?

multithreading - 多线程方法与 Akka Actor 模型

playframework-2.0 - 当存在多个测试用例时 Play 2.0 Akka 系统关闭

java - 生成具有一些限制的矩阵的所有可能配置

java - Tomcat 7 WAR 部署(Spring Boot)- 无法启动组件

akka - Actor 的行为应该在什么时候 split

java - java中的调用栈

java - 在自动化 Android 应用程序时,如何通过单击 appium 中的主页按钮导航到主屏幕?