Questions tagged [akka-dispatcher]
18 questions
7
votes
3 answers
Why are Futures within Futures running sequentially when started on Akka Dispatcher
We observed a strange behavior when we tried to start a number of futures from within an actor's receive method.
If we use our configured dispatchers as ExecutionContext, the futures run on the same thread and sequentially. If we use…
Joshua Esolk
- 103
- 6
3
votes
1 answer
Akka Streams Reactive Kafka - OutOfMemoryError under high load
I am running an Akka Streams Reactive Kafka application which should be functional under heavy load. After running the application for around 10 minutes, the application goes down with an OutOfMemoryError. I tried to debug the heap dump and found…
dks551
- 1,113
- 1
- 15
- 39
2
votes
1 answer
Akka Balancing Pool with variable-size Thread-Pool-Executor
Here is my use case:
I want to create a Balancing-Pool router of size x (x is the number of instances/routees that is determined at runtime) with each of the routees having its own dedicated thread.
Each of the routees is expected to perform…
AJ Jwair
- 45
- 1
- 5
1
vote
1 answer
Why the actorSystem is not creating the actor to run with custom dispatcher
Hi have below typesafe config in file application-typed.conf.
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "DEBUG"
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
actor {
provider = "local"
…
user51
- 8,843
- 21
- 79
- 158
1
vote
1 answer
How to configure dispatcher correctly in asp.net core akka
I am adding a pinned dispatcher to my akka.net configuration as I read this will give a timely manner to my dispatch messages to my actor but as I followed akka configuration I came up with this
using (_actorSystem =…
Yabetsu2018
- 133
- 1
- 15
1
vote
2 answers
Why Akka shutdowns dispatcher, when there is no tasks?
I want to have fixed thread pool with once created threads. So, I create own ExecutorServiceConfigurator:
class FixedThreadPoolExecutorServiceConfigurator(config: Config, prerequisites: DispatcherPrerequisites) extends…
Denis
- 3,595
- 12
- 52
- 86
1
vote
1 answer
What does the "throughput-deadline-time" configuration option do?
I've stumbled on the throughput-deadline-time configuration property for Akka dispatchers, and it looks like an interesting option, however the only mention of it I could find in the whole documentation is the following:
# Throughput deadline for…
LordOfThePigs
- 11,050
- 7
- 45
- 69
0
votes
0 answers
Issue with pruning in Remember entities of Actor Cluster Sharding
In a 3-node Actor cluster, during a rolling restart of nodes, some of the newly created entity entries overwrite the old values for certain keys in Remember entities ORSet.
This issue when pruning occures after the restart. The shards in the cluster…
Arun
- 67
- 11
0
votes
1 answer
Make Akka guardian actor use custom dispatcher
I have defined a custom dispatcher in application.conf like this:
my-special-dispatcher {
type = Dispatcher
executor = "thread-pool-executor"
thread-pool-executor {
fixed-pool-size = 1
}
throughput = 1
}
The documentation says to…
JoeMjr2
- 3,804
- 4
- 34
- 62
0
votes
1 answer
Which dispatcher configuration in AKKA is efficient for more no of actor processing in parallel?
When we us pinned dispatcher we have to assign a single thread for an actor.
In Default dispatcher we have a thread pool with a allocated threads used by many actors.
If we use a dispatcher with 1000 threads and for a 5000 actors sharing that.
How…
Arun
- 67
- 11
0
votes
1 answer
How to handle million individual actors with AKKA Cluster setup?
I have a use case which is million clients data processed by individual actor.And all the actors created on across multiple nodes and formed as a cluster.
When i receive a message i have to send it to the particular actor in the cluster which is…
Arun
- 67
- 11
0
votes
1 answer
When to use more instances of same Akka actor?
I've been working with Akka for some time, but now am exploring its actor system in depth. I know there is thread poll executor and fork join executor and afinity executor. I know how dispatcher works and all the rest details. BTW, this link gives a…
aldm
- 343
- 1
- 11
0
votes
1 answer
Actor message allocation to dispatcher thread
It is known that Dispatcher threads are responsible for executing the actor messages. Using throughput parameter we can define no. of messages processed by dispatcher thread before moving to another actor
But I am not sure about how dispatcher…
Hemnath
- 255
- 1
- 3
- 13
0
votes
1 answer
Akka Dispatcher Thread creation
I have been working on Akka Actor model. I have an usecase where more than 1000 actors will be in active and I have to process those actors. I thought of controlling the thread count through configuration defined in the application.conf.
But no. of…
Hemnath
- 255
- 1
- 3
- 13
0
votes
0 answers
How do I control the run-time execution of an actor system in Akka?
I have been trying to figure out a way to control the run-time message passing within an actor system with some sort of external (separate from the actor system) controller. In other words, given an actor system (that I do not want to change): how…
Randyll Tarly
- 1
- 1