我有一个接收消息的演员 - 也就是说,它通常会快速连续收到几条消息,然后长时间不活动.当actor没有收到250ms的消息时,我想执行代码.
只是为了澄清我的意思,在Javascript中,我可能会写一些像这样的代码:
function gotMessage() {
if(this.idleTimeout) {
clearTimeout(this.idleTimeout);
}
this.idleTimeout = setTimeout(function() {
//My code here
}, 250);
}
Run Code Online (Sandbox Code Playgroud)
我如何在Scala或Akka中实现这种效果,如果它已经存在于该库中的机制?