When I send 300, 000 message from one actor to another (all local), more than 90% time of first the source actor is spent in Dispatcher.registerForExecution(), inside it, there is executorService.execute(mbox)
The Mailbox.run will first try to process pending messages, when there is no pending messages, when there is no messages, then current runnable will exit. So for the worst case, 300, 000 messages dispatch to mailbox, which also have 300, 000 call for executorService.execute(mbox), which will cause performance issue. What we can do for this? 300, 000 message per pair of actors is not good enough. -- >>>>>>>>>> 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.
