Update ControlledWorkerScheduler.java

ponder-lab · Aug 5, 2024 · 2bd6e75 · 2bd6e75
1 parent 1868faf
commit 2bd6e75
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...ain/java/org/eclipse/rdf4j/federated/evaluation/concurrent/ControlledWorkerScheduler.java b/...ain/java/org/eclipse/rdf4j/federated/evaluation/concurrent/ControlledWorkerScheduler.java
@@ -12,9 +12,9 @@
 
 import java.util.List;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 
 import org.eclipse.rdf4j.common.iteration.CloseableIteration;
@@ -117,8 +117,10 @@ public int getNumberOfTasks() {
 	}
 
 	private ExecutorService createExecutorService() {
-
-		ExecutorService executor = Executors.newThreadPerTaskExecutor(new NamingThreadFactory(name));
+		// Refactoring this causes ServicesTest to hang forever (https://github.com/ponder-lab/rdf4j/actions/runs/10239404923/job/28324948852?pr=2)
+		ThreadPoolExecutor executor = new ThreadPoolExecutor(nWorkers, nWorkers, 60L, TimeUnit.SECONDS, _taskQueue,
+				new NamingThreadFactory(name));
+		executor.allowCoreThreadTimeOut(true);
 		return executor;
 	}