Re: [akka-user] problem with pinned dispatcher

[mc]

I got this to work by defining actor group, see my other post ("how to bind 
each actor in a pool to a thread").
Thanks,

M



On Tuesday, August 1, 2017 at 12:31:36 PM UTC-7, Patrik Nordwall wrote:
>
> I don't think that is the right way to define the dispatcher for router 
> pool. See docs 
> http://doc.akka.io/docs/akka/current/scala/routing.html#configuring-dispatchers
>
> /Patrik
>
>
> tis 1 aug. 2017 kl. 20:40 skrev Viktor Klang  >:
>
>> «Note that it’s not guaranteed that the *same* thread is used over time, 
>> since the core pool timeout is used for PinnedDispatcher to keep 
>> resource usage down in case of idle actors. To use the same thread all the 
>> time you need to add thread-pool-executor.allow-core-timeout=off to the 
>> configuration of the PinnedDispatcher.»
>>
>>
>> http://doc.akka.io/docs/akka/current/scala/dispatchers.html#types-of-dispatchers
>>
>>
>>
>> On Tue, Aug 1, 2017 at 5:04 PM, mc  
>> wrote:
>>
>>> Hello,
>>>
>>> I'm trying to use PinnedDispatcher using the following configuration (in 
>>> application.conf):
>>>
>>> app {
>>> pinnedDispatcher {
>>> type = "PinnedDispatcher"
>>> executor = "thread-pool-executor"
>>> thread-pool-executor.allow-
>>> core-timeout = off
>>> thread-pool-executor {
>>> core-pool-size-min = 2
>>> core-pool-size-factor = 2.0
>>> core-pool-size-max = 4
>>> }
>>> throughput = 1
>>> }
>>> }
>>>
>>> akka.actor.deployment {
>>> /master/worker {
>>> dispatcher = app.pinnedDispatcher
>>> router = round-robin-pool
>>> }
>>> }
>>>
>>> This is my code for creating worker pool (inside MyMaster actor called 
>>> "master"):
>>>   private lazy val worker = 
>>> context.actorOf(FromConfig.props(Props[MyWorker]), "worker")
>>>
>>> Worker actors are receiving messages but it looks like actors created on 
>>> one thread are later executed on another thread.
>>> Is my configuration incorrect? I thought that using pinned dispatcher 
>>> would guarantee that an actor created on a thread would later be always 
>>> called from that same thread.
>>> I'd appreciate any help with this problem.
>>> Thanks,
>>>
>>> M
>>>
>>> -- 
>>> >> 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+...@googlegroups.com .
>>> To post to this group, send email to akka...@googlegroups.com 
>>> .
>>> Visit this group at https://groups.google.com/group/akka-user.
>>> For more options, visit https://groups.google.com/d/optout.
>>>
>>
>>
>>
>> -- 
>> Cheers,
>> √
>>
>> -- 
>> >> 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+...@googlegroups.com .
>> To post to this group, send email to akka...@googlegroups.com 
>> .
>> Visit this group at https://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user] problem with pinned dispatcher

[Viktor Klang]

«Note that it’s not guaranteed that the *same* thread is used over time,
since the core pool timeout is used for PinnedDispatcher to keep resource
usage down in case of idle actors. To use the same thread all the time you
need to add thread-pool-executor.allow-core-timeout=off to the
configuration of the PinnedDispatcher.»

http://doc.akka.io/docs/akka/current/scala/dispatchers.html#types-of-dispatchers


On Tue, Aug 1, 2017 at 5:04 PM, mc  wrote:

> Hello,
>
> I'm trying to use PinnedDispatcher using the following configuration (in
> application.conf):
>
> app {
> pinnedDispatcher {
> type = "PinnedDispatcher"
> executor = "thread-pool-executor"
> thread-pool-executor.allow-
> core-timeout = off
> thread-pool-executor {
> core-pool-size-min = 2
> core-pool-size-factor = 2.0
> core-pool-size-max = 4
> }
> throughput = 1
> }
> }
>
> akka.actor.deployment {
> /master/worker {
> dispatcher = app.pinnedDispatcher
> router = round-robin-pool
> }
> }
>
> This is my code for creating worker pool (inside MyMaster actor called
> "master"):
>   private lazy val worker = context.actorOf(FromConfig.props(Props[MyWorker]),
> "worker")
>
> Worker actors are receiving messages but it looks like actors created on
> one thread are later executed on another thread.
> Is my configuration incorrect? I thought that using pinned dispatcher
> would guarantee that an actor created on a thread would later be always
> called from that same thread.
> I'd appreciate any help with this problem.
> Thanks,
>
> M
>
> --
> >> 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 https://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 
Cheers,
√

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] problem with pinned dispatcher

[mc]

Hello,

I'm trying to use PinnedDispatcher using the following configuration (in 
application.conf):

app {
pinnedDispatcher {
type = "PinnedDispatcher"
executor = "thread-pool-executor"
thread-pool-executor.allow-
core-timeout = off
thread-pool-executor {
core-pool-size-min = 2
core-pool-size-factor = 2.0
core-pool-size-max = 4
}
throughput = 1
}
}

akka.actor.deployment {
/master/worker {
dispatcher = app.pinnedDispatcher
router = round-robin-pool
}
}

This is my code for creating worker pool (inside MyMaster actor called 
"master"):
  private lazy val worker = 
context.actorOf(FromConfig.props(Props[MyWorker]), "worker")

Worker actors are receiving messages but it looks like actors created on 
one thread are later executed on another thread.
Is my configuration incorrect? I thought that using pinned dispatcher would 
guarantee that an actor created on a thread would later be always called 
from that same thread.
I'd appreciate any help with this problem.
Thanks,

M

-- 
>>  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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.