Skip to content

Commit

Permalink
migrated all internal dispatchers off the dedicated thread pool and o…
Browse files Browse the repository at this point in the history
…nto default thread pool (#7117)
  • Loading branch information
Aaronontheweb authored Mar 11, 2024
1 parent ffa9258 commit 251622d
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
10 changes: 5 additions & 5 deletions src/core/Akka.Persistence/persistence.conf
Original file line number Diff line number Diff line change
Expand Up @@ -77,21 +77,21 @@ akka.persistence {
# Dispatcher used by every plugin which does not declare explicit
# `plugin-dispatcher` field.
default-plugin-dispatcher {
type = PinnedDispatcher
executor = "fork-join-executor"
type = Dispatcher
executor = "default-executor"
}
# Default dispatcher for message replay.
default-replay-dispatcher {
type = ForkJoinDispatcher
executor = "fork-join-executor"
type = Dispatcher
executor = "default-executor"
dedicated-thread-pool {
# Fixed number of threads to have in this threadpool
thread-count = 8
}
}
# Default dispatcher for streaming snapshot IO
default-stream-dispatcher {
type = ForkJoinDispatcher
type = Dispatcher
dedicated-thread-pool {
# Fixed number of threads to have in this threadpool
thread-count = 8
Expand Down
4 changes: 2 additions & 2 deletions src/core/Akka.Remote/Configuration/Remote.conf
Original file line number Diff line number Diff line change
Expand Up @@ -570,7 +570,7 @@ akka {
### Default dispatcher for the remoting subsystem

default-remote-dispatcher {
executor = fork-join-executor
executor = default-executor
fork-join-executor {
parallelism-min = 2
parallelism-factor = 0.5
Expand All @@ -580,7 +580,7 @@ akka {
}

backoff-remote-dispatcher {
executor = fork-join-executor
executor = default-executor
fork-join-executor {
parallelism-min = 2
parallelism-max = 2
Expand Down
4 changes: 2 additions & 2 deletions src/core/Akka/Configuration/akka.conf
Original file line number Diff line number Diff line change
Expand Up @@ -389,7 +389,7 @@ akka {
# default dispatcher)
internal-dispatcher {
type = "Dispatcher"
executor = "fork-join-executor"
executor = "default-executor"
throughput = 5

fork-join-executor {
Expand All @@ -402,7 +402,7 @@ akka {

default-blocking-io-dispatcher {
type = "Dispatcher"
executor = "thread-pool-executor"
executor = "default-executor"
throughput = 1

# Akka.NET does not have a fine grained control over thread pool executor
Expand Down

0 comments on commit 251622d

Please sign in to comment.