我们有一个Akka演员正在读取包含许多文件的大文件夹。
它读取它们以供其他演员处理。
似乎读取速度太快,最终我们遇到了OutOfMemoryException
。
我们想知道是否可以在X时间内以某种方式pause/sleep
?
最佳答案
您可以自己暂停它,这意味着您应该让演员停止处理文件并设置一个计时器,以在X秒/分钟后向自己发送resume
消息。
但是...您永远找不到合适的时间(上面的X),它总是太长或太短。这种问题就是为什么akka-stream存在的原因。我建议您看看它,因为它是解决此类问题的唯一好方法。