scala Actor : drop messages if queue is too long?

Question

如果 Actor 的邮箱太满，我想从 Actor 的邮箱中删除消息。例如，如果队列大小达到 1000 条消息，则应删除最旧的消息。

Answer 1

不能直接使用邮箱，但可以实现Message Expiration现有库之上的模式。

在每条消息中发送创建日期:

case class ExpirableMessage(msg: String, createdAt: Long) 

用reactWithin(0)扫描邮箱，过滤掉过期邮件:

react{ 
  case msg: ExpirableMessage => 
    // handle the message
    // clean the mailbox with nested react
    reactWithin(0){
        case ExpirableMessage(_, createdAt) if(currentTimeMillis - createdAt > INTERVAL) =>
        case TIMEOUT =>
    }
}