give names to NEI threads (#540)

GTNewHorizons · Oct 4, 2024 · 43918f3 · 43918f3
1 parent a41299d
commit 43918f3
Showing 1 changed file with 17 additions and 6 deletions.
diff --git a/src/main/java/codechicken/nei/ItemList.java b/src/main/java/codechicken/nei/ItemList.java
@@ -8,6 +8,7 @@
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.ForkJoinWorkerThread;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
@@ -322,14 +323,24 @@ public void execute() {
         }
     };
 
-    public static ForkJoinPool getPool(int poolSize) {
-        if (poolSize < 1) poolSize = 1;
+    public static ForkJoinPool forkJoinPool;
 
-        return new ForkJoinPool(poolSize);
-    }
+    static {
+        final ForkJoinPool.ForkJoinWorkerThreadFactory factory = new ForkJoinPool.ForkJoinWorkerThreadFactory() {
+
+            private int workerId;
 
-    public static final int numProcessors = Runtime.getRuntime().availableProcessors();
-    public static ForkJoinPool forkJoinPool = getPool(numProcessors * 2 / 3);
+            @Override
+            public ForkJoinWorkerThread newThread(ForkJoinPool pool) {
+                final ForkJoinWorkerThread worker = ForkJoinPool.defaultForkJoinWorkerThreadFactory.newThread(pool);
+                worker.setName("NEI-worker-thread-" + workerId++);
+                return worker;
+            }
+        };
+        int poolSize = Runtime.getRuntime().availableProcessors() * 2 / 3;
+        if (poolSize < 1) poolSize = 1;
+        forkJoinPool = new ForkJoinPool(poolSize, factory, null, false);
+    }
 
     public static final RestartableTask updateFilter = new RestartableTask("NEI Item Filtering") {