We're running Akka 2.3.7 (Java) and I'm now working on reconfiguring to
scale for more throughput (as it apparently isn't happening).
I am struggling with the Akka documentation as well as some of the examples
out there as there is always some contextual information that seems to be
missing.
However, in order to make sure I'm not going mad, I've extracted the code
and config in a dead-simple unit test (I even removed akka's JavaTestKit).
The code and config here suggest that there should be a lot of messages
processed in parallel, however the entire processing is totally serialised
and I can't understand where have I failed in this setup.
Any suggestion would be helpful.
Thank you
Cos
@Test
public void testAkka() throws Exception {
Config cfg = ConfigFactory.load("test-akka.conf");
ActorSystem actorSystem = ActorSystem.create("main", cfg.getConfig("main"));
ActorRef actorRef = actorSystem.actorOf(Props.create(MyActor.class),
"myactor");
for (int i = 0; i < 150; i++) {
actorRef.tell("nothing", ActorRef.noSender());
}
Thread.sleep(1000000);
}
public static final class MyActor extends UntypedActor {
@Override
public void onReceive(Object message) throws Exception {
System.out.println("Doing stuff");
Thread.sleep(2000);
}
}
And the test-akka.conf file
main {
app-dispatcher {
type = Dispatcher
executor = "fork-join-executor"
fork-join-executor {
parallelism-min = 16
parallelism-factor = 32.0
parallelism-max = 512
}
throughput = 1
}
akka.actor.deployment {
/myactor {
dispatcher = app-dispatcher
router = round-robin-pool
nr-of-instances = 16
}
}
}
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
