fix(threads): back out #1388 Vertexecutor where not strictly required

Signed-off-by: Andrew Azores <aazores@redhat.com>
cryostatio · Apr 13, 2023 · e8408a5 · e8408a5
1 parent 611140a
commit e8408a5
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 9 deletions.
diff --git a/src/main/java/io/cryostat/net/openshift/OpenShiftNetworkModule.java b/src/main/java/io/cryostat/net/openshift/OpenShiftNetworkModule.java
@@ -50,7 +50,6 @@
 import io.cryostat.core.sys.Environment;
 import io.cryostat.core.sys.FileSystem;
 import io.cryostat.net.AuthManager;
-import io.cryostat.net.web.WebModule;
 import io.cryostat.util.resource.ClassPropertiesLoader;
 
 import com.github.benmanes.caffeine.cache.Scheduler;
@@ -123,7 +122,7 @@ static OpenShiftClient provideServiceAccountClient(
     @Singleton
     static OpenShiftAuthManager provideOpenShiftAuthManager(
             Environment env,
-            @Named(WebModule.VERTX_EXECUTOR) ExecutorService executor,
+            ExecutorService executor,
             @Named(OPENSHIFT_NAMESPACE) Lazy<String> namespace,
             Lazy<OpenShiftClient> serviceAccountClient,
             @Named(TOKENED_CLIENT) Function<String, OpenShiftClient> clientProvider,

diff --git a/src/main/java/io/cryostat/net/web/Vertexecutor.java b/src/main/java/io/cryostat/net/web/Vertexecutor.java
@@ -1,4 +1,3 @@
-package io.cryostat.net.web;
 /*
  * Copyright The Cryostat Authors
  *
@@ -37,6 +36,8 @@
  * SOFTWARE.
  */
 
+package io.cryostat.net.web;
+
 import java.util.List;
 import java.util.concurrent.AbstractExecutorService;
 import java.util.concurrent.TimeUnit;

diff --git a/src/main/java/io/cryostat/platform/internal/PlatformStrategyModule.java b/src/main/java/io/cryostat/platform/internal/PlatformStrategyModule.java
@@ -40,8 +40,6 @@
 import java.util.Set;
 import java.util.concurrent.ExecutorService;
 
-import javax.inject.Named;
-
 import io.cryostat.core.log.Logger;
 import io.cryostat.core.net.JFRConnectionToolkit;
 import io.cryostat.core.net.discovery.JvmDiscoveryClient;
@@ -50,7 +48,6 @@
 import io.cryostat.net.NetworkResolver;
 import io.cryostat.net.NoopAuthManager;
 import io.cryostat.net.openshift.OpenShiftAuthManager;
-import io.cryostat.net.web.WebModule;
 
 import com.google.gson.Gson;
 import dagger.Lazy;
@@ -69,7 +66,7 @@ static Set<PlatformDetectionStrategy<?>> providePlatformDetectionStrategies(
             Lazy<OpenShiftAuthManager> openShiftAuthManager,
             Lazy<NoopAuthManager> noopAuthManager,
             Lazy<JFRConnectionToolkit> connectionToolkit,
-            @Named(WebModule.VERTX_EXECUTOR) ExecutorService executor,
+            ExecutorService executor,
             Vertx vertx,
             Gson gson,
             NetworkResolver resolver,

diff --git a/src/main/java/io/cryostat/recordings/RecordingsModule.java b/src/main/java/io/cryostat/recordings/RecordingsModule.java
@@ -176,7 +176,7 @@ static RecordingMetadataManager provideRecordingMetadataManager(
             // CONFIGURATION_PATH
             @Named(ConfigurationModule.CONFIGURATION_PATH) Path confDir,
             @Named(MainModule.RECORDINGS_PATH) Path archivedRecordingsPath,
-            @Named(WebModule.VERTX_EXECUTOR) ExecutorService executor,
+            ExecutorService executor,
             @Named(Variables.JMX_CONNECTION_TIMEOUT) long connectionTimeoutSeconds,
             FileSystem fs,
             Provider<RecordingArchiveHelper> archiveHelperProvider,
@@ -223,7 +223,7 @@ static RecordingMetadataManager provideRecordingMetadataManager(
     @Singleton
     static JvmIdHelper provideJvmIdHelper(
             TargetConnectionManager targetConnectionManager,
-            @Named(WebModule.VERTX_EXECUTOR) ExecutorService executor,
+            ExecutorService executor,
             @Named(Variables.JMX_CONNECTION_TIMEOUT) long connectionTimeoutSeconds,
             CredentialsManager credentialsManager,
             DiscoveryStorage storage,

diff --git a/src/main/java/io/cryostat/sys/SystemModule.java b/src/main/java/io/cryostat/sys/SystemModule.java
@@ -37,6 +37,9 @@
  */
 package io.cryostat.sys;
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.ForkJoinPool;
+
 import javax.inject.Singleton;
 
 import io.cryostat.core.sys.Clock;
@@ -65,4 +68,10 @@ static Environment provideEnvironment() {
     static FileSystem provideFileSystem() {
         return new FileSystem();
     }
+
+    @Provides
+    @Singleton
+    static ExecutorService provideExecutorService() {
+        return ForkJoinPool.commonPool();
+    }
 }