1

私は Akka を初めて使用し、入門シリーズに取り組もうとしています。Dispatcher を構成することができたので、PinnedDispatcher を構成しようとしています。はじめにのページの指示に従っているのに、エラー メッセージが表示される

[WARN] [06/19/2013 12:53:13.791] [System-akka.actor.default-dispatcher-5] [Dispatchers] Dispatcher [akka.actor.my-pinned-dispatcher] not configured, using default-dispatcher

スカラコードは次のとおりです。

val system = ActorSystem("System")
val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-pinned-dispatcher")) //this doesnt work

val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-dispatcher")) //this does work

a ! "Hello World"

system.shutdown()

class TestActor extends Actor {
def receive = {
    case s: String => println(s)
}
}

ここに私のapplication.confがあります

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

    my-dispatcher {
        type = Dispatcher

        executor = "fork-join-executor"

        fork-join-executor {
            parallelism-min = 2

            parallelism-factor = 2.0

            parallelism-max = 10
        }

        throughput = 100
    }
}
}

PinnedDispatcher を間違って構成しましたか?

4

0 に答える 0