爲什麼我在Akka調度演員？

Question

我有一個演員池，其中有100個運行Actor，它們共享一個工作，將其CorePoolSize設置爲100，但將現有的19個消息發送給其中一個演員時，19個消息不會並行化爲19個演員，但只有5個消息並行運行。當這5條消息完成後，接下來的5條消息再次由這些相同的5個角色處理，依此類推。爲什麼我的19條信息並行運行，我在這裏錯過了什麼？

我的代碼基本上是這樣的：

object TestActor { 
    val dispatcher = Dispatchers.newExecutorBasedEventDrivenWorkStealingDispatcher("pool") 
        .setCorePoolSize(100) 
        .setMaxPoolSize(100) 
        .build 
} 

class TestActor(val name: Integer) extends Actor { 
    self.lifeCycle = Permanent 
    self.dispatcher = TestActor.dispatcher 
    def receive = { 
     case num: Integer => { println("Actor: " + name + " Received: " + num) 
           Thread.sleep(10000) 
          } 
    } 
} 

trait CyclicLoadBalancing extends LoadBalancer { this: Actor => 
    val testActors: List[ActorRef] 
    val seq = new CyclicIterator[ActorRef](testActors) 
} 

trait TestActorManager extends Actor { 
    self.lifeCycle = Permanent 
    self.faultHandler = OneForOneStrategy(List(classOf[Exception]), 5, 5000) 
    val testActors: List[ActorRef] 
    override def preStart = testActors foreach { self.startLink(_) } 
    override def postStop = self.shutdownLinkedActors() 
} 

val supervisor = actorOf(new TestActorManager with CyclicLoadBalancing { 
val testActors = (1 until 100 toList) map (i => actorOf(new TestActor(i))) 
}).start 

println("Number of Actors: " + Actor.registry.actorsFor(classOf[TestActor]).length) 

val testActor = Actor.registry.actorsFor(classOf[TestActor]).head 

(1 until 20 toList) foreach { testActor ! _ } 

輸出：

Actor: 4 Received: 16 
Actor: 3 Received: 17 
Actor: 1 Received: 19 
Actor: 59 Received: 1 
Actor: 2 Received: 18 

// 10 secs. are passing.. 

Actor: 4 Received: 15 
Actor: 3 Received: 14 
Actor: 1 Received: 13 
Actor: 59 Received: 2 
Actor: 2 Received: 12 

// 10 secs. are passing.. 

Actor: 4 Received: 11 
Actor: 3 Received: 10 
Actor: 59 Received: 3 
Actor: 2 Received: 8 
Actor: 1 Received: 9 

// 10 secs. are passing.. 

Actor: 4 Received: 7 
Actor: 3 Received: 6 
Actor: 59 Received: 4 
Actor: 2 Received: 5 

編輯：我使用阿卡1.0

Answer 1

我覺得調度允許您自定義的吞吐量性能。這定義了調度員應該在一次掃描中處理的特定Actor的消息數量。你可以在你的akka​​.conf文件

actor { 
    throughput = 20 
} 

添加以下配置默認情況下爲5個

Answer 2

感謝您的詢問，我本地化瓶頸，它固定在此承諾阿卡大師：

https://github.com/akka/akka/commit/e4e99ef56399e892206ce4a46b9a9107da6c7770

將在阿卡1.1-RC1發佈

乾杯， √