Great investigative work! Thanks for letting us know what was the problem.
On Wed, Nov 26, 2014 at 5:22 AM, Soumya Simanta <soumya.sima...@gmail.com>
wrote:
> I stand corrected. The blocking is not happening at Unsafe.park but the
> following
>
> ch.qos.logback.core.AppenderBase.doAppend(Object) AppenderBase.java:64
> ch.qos.logback.classic.Logger.info(String) Logger.java:607
>
> I removed the calls to the logger and its working now.
> Reporting here just in case someone else is facing the same/similar issue.
>
>
>
> On Tuesday, November 25, 2014 6:13:09 PM UTC-5, Soumya Simanta wrote:
>>
>> I'm using the following Scala and Akka versions.
>>
>> scalaVersion := "2.10.3"
>> val akkaVersion = "2.3.6"
>>
>>
>>
>> On Tuesday, November 25, 2014 5:39:52 PM UTC-5, Soumya Simanta wrote:
>>>
>>> Looks like the following is the call that blocks.
>>>
>>> ForkJoinPool.java:2075 sun.misc.Unsafe.park(boolean, long)
>>>
>>>
>>>
>>> On Tuesday, November 25, 2014 12:12:14 PM UTC-5, Soumya Simanta wrote:
>>>>
>>>> Not all threads in my dispatcher are running to 100%.
>>>> Following is my dispatcher.
>>>>
>>>> my-dispatcher{
>>>> type = Dispatcher
>>>> executor = "fork-join-executor"
>>>> fork-join-executor {
>>>> # Min number of threads to cap factor-based parallelism number to
>>>> parallelism-min = 8
>>>> # Parallelism (threads) ... ceil(available processors * factor)
>>>> parallelism-factor = 2.0
>>>> # Max number of threads to cap factor-based parallelism number to
>>>> parallelism-max = 120
>>>> }
>>>> throughput = 200
>>>> }
>>>>
>>>> I'm calling my actors using a router.
>>>>
>>>> val actor = context.actorOf(Props(new MyActor(pubRedisClient,
>>>> pubChanName)).withRouter(SmallestMailboxRouter(nrOfInstances =
>>>> 20)).withDispatcher("akka.my-dispatcher"), name = "my-analyzer-router")
>>>>
>>>> What I cannot understand is that all threads in my dispatching go into
>>>> the blocking state at the same time (please see the screenshots). Looks
>>>> like this is happening consistently. My intuition is if there is a blocking
>>>> piece of code then it's very strange that the blocking piece is being
>>>> executed at the exact same time again and again.
>>>>
>>>> Any idea why this would be happening?
>>>>
>>>> Thanks
>>>> -Soumya
>>>>
>>>>
>>>>
>>>>
>>>>
>>>> --
> >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at http://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>
--
Martynas Mickevičius
Typesafe <http://typesafe.com/> – Reactive
<http://www.reactivemanifesto.org/> Apps on the JVM
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
