+ using work stealing pool

q3769 · May 11, 2024 · 8b391a9 · 8b391a9
1 parent 41b3a55
commit 8b391a9
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/main/java/conottle/Conottle.java b/src/main/java/conottle/Conottle.java
@@ -53,12 +53,11 @@ public final class Conottle implements ClientTaskExecutor, AutoCloseable {
 
     @Builder
     private Conottle(int maxClientsPermitted, int maxParallelismPerClient, ExecutorService workerExecutorService) {
-        maxClientsPermitted = requireNonNegativeOrThrow(maxClientsPermitted);
-        this.activeThrottlingExecutors = new ConcurrentHashMap<>(maxClientsPermitted);
-        this.clientTotalThrottle = new Semaphore(maxClientsPermitted);
+        this.activeThrottlingExecutors = new ConcurrentHashMap<>(requireNonNegativeOrThrow(maxClientsPermitted));
+        this.clientTotalThrottle = new Semaphore(requireNonNegativeOrThrow(maxClientsPermitted));
         this.maxParallelismPerClient = requireNonNegativeOrThrow(maxParallelismPerClient);
         this.workerExecutorService =
-                workerExecutorService == null ? Executors.newFixedThreadPool(DEFAULT_MAX) : workerExecutorService;
+                workerExecutorService == null ? Executors.newWorkStealingPool(DEFAULT_MAX) : workerExecutorService;
     }
 
     private static int requireNonNegativeOrThrow(int value) {