1. 程式人生 > >AKKA文件(JAVA版)—派發器

AKKA文件(JAVA版)—派發器

更多派發器配置例子

配置PinnedDispatcher:

my-pinned-dispatcher {
  executor = "thread-pool-executor"
  type = PinnedDispatcher
}

接著使用它:

ActorRef myActor = system.actorOf(Props.create(MyUntypedActor.class)
    .withDispatcher("my-pinned-dispatcher"));

注意:thread-pool-executor 配置按照上面my-thread-pool-dispatcher例子是不適用的。這是因為當使用PinnedDispatcher時候,每一個角色將有自己的執行緒池,執行緒池將只有一個執行緒。

注意:隨著時間推移這將不保證一直使用相同執行緒,由於核心池超時用於PinnedDispatcher 在閒置角色情況下,降低資源使用。為了一直使用相同的執行緒,你需要新增 thread-pool-executor.allow-core-timeout=off到PinnedDispatcher配置中。