Skip to content

Commit

Permalink
fix issue with forkjoin (#1245)
Browse files Browse the repository at this point in the history
  • Loading branch information
pjfanning committed Mar 31, 2024
1 parent aba2785 commit 276a757
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 276a757

Please sign in to comment.