From 276a757d7763fbd0b02276d6a632bdf3a0e158fe Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Sun, 31 Mar 2024 19:12:45 +0200 Subject: [PATCH] fix issue with forkjoin (#1245) --- .../apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/actor/src/main/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala b/actor/src/main/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala index 71d2ffc750..661dfb8dd7 100644 --- a/actor/src/main/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala +++ b/actor/src/main/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfigurator.scala @@ -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)