斯卡拉演員不按預期工作

Question

我想讓演員工作，但它只能部分工作。

MyActor每秒工作並通過循環調用自身來運行Job。

這部分工作正常。

我也想從我的應用程序的其他部分隨機調用MyActor。

這不行。

MyActor遞增其mailboxSize，但隨後繼續循環，並且從不獲取從外部發送的任何消息。

case class DoJob(fast:Boolean) 

object MyActor extends Actor { 

    def act = { 
    loop { 
     MyActor ! DoJob(false) 
     receive { 
     case DoJob(fast) => { 
      Job.perform(fast) 
     } 
     } 
     Thread.sleep(1000) 
    } 
    } 
} 

以下呼籲方面不起作用DoJob（真），但僅僅增加MyActor的郵箱大小：

MyActor ! DoJob(true) 

出了什麼問題嗎？

Answer 1

每次撥打receive只會收到一封郵件。由於您在致電接收之前向您自己發送一條消息，因此您永遠不會減少該環路中的郵箱大小。

您應該製作一個單獨的線程來發送心跳，或使用​​和TIMEOUT的情況。