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

它读取它们以供其他演员处理。

似乎读取速度太快,最终我们遇到了OutOfMemoryException

我们想知道是否可以在X时间内以某种方式pause/sleep

最佳答案

您可以自己暂停它,这意味着您应该让演员停止处理文件并设置一个计时器,以在X秒/分钟后向自己发送resume消息。

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

10-06 11:26
查看更多