X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.impl%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fimpl%2Fquery%2FQueryThread.java;h=7aa89b3f032ea68f08e75f1d65bd0c0e87bdc030;hp=cfa088a2dbfd7a966e0af3db7f4d9a5aa5d1ad4c;hb=a88c02c2d0f4250caf887a130b9f4314c6564722;hpb=785f638bab44e70ec6103c3891daea95bcda9a07

diff --git a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryThread.java b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryThread.java
index cfa088a2d..7aa89b3f0 100644
--- a/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryThread.java
+++ b/bundles/org.simantics.db.impl/src/org/simantics/db/impl/query/QueryThread.java
@@ -98,17 +98,7 @@ class QueryThread extends Thread implements SessionThread {
 	}
 
 	private boolean pumpTask() {
-	    // First finish existing executions
-        if(!processor.freeScheduling.isEmpty()) {
-            tasks.add(processor.freeScheduling.removeFirst());
-            return true;
-        }
-        // Check for new tasks
-        if(!processor.topLevelTasks.isEmpty()) {
-            tasks.add(processor.topLevelTasks.removeFirst());
-            return true;
-        }
-		return false;
+	    return processor.scheduling.pumpTask(tasks);
 	}
 	
 	ArrayList<SessionTask> newTasks(boolean doWait, ArrayList<SessionTask> tasks) {