Scala,Actors,未读收件箱邮件会发生什么？

Question

Scala Actors中未读收件箱邮件会发生什么？例如两种情况:1.如果忘记为特殊消息实施反应案例:2.如果消息过快:如果发生第一种或第二种情况,它是否会堆叠在内存中？



actor!NoReactCaseMessage



(timeOfProcessingMessage > timeOfMessageComes)

编辑1有没有机制看到这种类型的内存泄漏发生？也许,控制未读消息的数量然后进行一些垃圾收集或增加演员池.如何获取未读邮件的数量？这种内存泄漏如何在其他语言中解决？比如在Erlang？

Answer 1

邮箱是一个队列-如果不从队列中拉出消息(即,如果在你的部分功能react或receive循环的回报false的isDefinedAt),那么这些消息只是呆在那里.

严格来说,这是一个内存泄漏(你的应用程序),虽然它的严重性取决于这些未读消息的数量如何增长(显然).例如,我经常使用actor来合并重放查询和由序列号标识的消息的"实时流".我的反应如下:

var lastSeq = 0L
loop {
  react {
    case Msg(seq, data) if seq > lastSeq => lastSeq = seq; process(data)
  }
}

这包含内存泄漏,但不是"严重"内存泄漏,因为重复消息的数量将存在上限(即,一旦重播查询完成,就不会有更多内容泄漏).

然而,这可能仍然是一个烦恼,因为对于每个反应,演员子系统将再次扫描这些消息以查看它们是否可以被处理.

事实上,考虑一个真正的邮箱可能是一个很好的类比.想象一下,你把所有的垃圾邮件留在那里:很快,你就会因为所有垃圾邮件而遭受饥饿,你必须筛选才能获得信用卡声明.