raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix issue with forkjoin (#1245)

Browse source
This commit is contained in:
PJ Fanning 2024-03-31 19:12:45 +02:00 • committed by GitHub
parent aba2785428
commit 276a757d77
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
actor/src/main/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala
View file

@ -118,7 +118,7 @@ class ForkJoinExecutorConfigurator(config: Config, prerequisites: DispatcherPrer
def createExecutorService: ExecutorService = pekkoJdk9ForkJoinPoolHandleOpt match {
case Some(handle) =>
handle.invokeExact(parallelism, threadFactory, maxPoolSize,
handle.invoke(parallelism, threadFactory, maxPoolSize,
MonitorableThreadFactory.doNothing, asyncMode).asInstanceOf[ExecutorService]
case _ =>
new PekkoForkJoinPool(parallelism, threadFactory, MonitorableThreadFactory.doNothing, asyncMode)