Use workStealingPool

tjake · Nov 4, 2023 · 03db246 · 03db246
1 parent 4cccd14
commit 03db246
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/jlama-core/src/main/java/com/github/tjake/jlama/util/PhysicalCoreExecutor.java b/jlama-core/src/main/java/com/github/tjake/jlama/util/PhysicalCoreExecutor.java
@@ -7,7 +7,7 @@
 import com.google.common.base.Suppliers;
 
 public class PhysicalCoreExecutor {
-    private static volatile int physicalCoreCount = Math.max(1, Runtime.getRuntime().availableProcessors());
+    private static volatile int physicalCoreCount = Math.max(1, Runtime.getRuntime().availableProcessors()/2);
     private static final AtomicBoolean started = new AtomicBoolean(false);
     public static void overrideThreadCount(int threadCount) {
         if (!started.compareAndSet(false, true))
@@ -25,7 +25,7 @@ public static void overrideThreadCount(int threadCount) {
 
     private PhysicalCoreExecutor(int cores) {
         assert cores > 0 && cores <= Runtime.getRuntime().availableProcessors() : "Invalid core count: " + cores;
-        this.pool = new ForkJoinPool(cores);
+        this.pool = new ForkJoinPool(cores, ForkJoinPool.defaultForkJoinWorkerThreadFactory, null, true);
     }
 
     public void execute(Runnable run) {