Added env config for worker pool threads

Author: RSam25

src/main/java/com/uid2/operator/Const.java

@@ -42,5 +42,7 @@ public class Config extends com.uid2.shared.Const.Config {
 
         public static final String ComputeHeavyRequestPoolThreadCountProp = "compute_heavy_request_pool_thread_count";
         public static final String EnableAsyncBatchRequestProp = "enable_async_batch_request";
+
+        public static final String DefaultWorkerPoolThreadCount = "default_worker_pool_thread_count";
     }
 }

src/main/java/com/uid2/operator/Main.java

@@ -505,10 +505,15 @@ private static Vertx createVertx() {
             ? 60 * 1000
             : 3600 * 1000;
 
+        // Worker pool size: read from env var, default to (cpus-2)/2 + 1 clamped to min 2
+        final int defaultWorkerPoolSize = Math.max(2, (Runtime.getRuntime().availableProcessors() - 2) / 2 + 1);
+        final int workerPoolSize = getEnvInt(Const.Config.DefaultWorkerPoolThreadCount, defaultWorkerPoolSize);
+        LOGGER.info("Creating Vertx with worker pool size: {}", workerPoolSize);
+
         VertxOptions vertxOptions = new VertxOptions()
             .setMetricsOptions(metricOptions)
             .setBlockedThreadCheckInterval(threadBlockedCheckInterval)
-            .setWorkerPoolSize(12);
+            .setWorkerPoolSize(workerPoolSize);
 
         return Vertx.vertx(vertxOptions);
     }
@@ -642,4 +647,17 @@ private IOperatorKeyRetriever createOperatorKeyRetriever() throws Exception {
             }
         }
     }
+
+    private static int getEnvInt(String name, int defaultValue) {
+        String value = System.getenv(name);
+        if (value == null || value.isEmpty()) {
+            return defaultValue;
+        }
+        try {
+            return Integer.parseInt(value);
+        } catch (NumberFormatException e) {
+            LOGGER.warn("Invalid integer value for environment variable {}: '{}', using default: {}", name, value, defaultValue);
+            return defaultValue;
+        }
+    }
 }