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=5510944dc319265e7e033e38a5462e62b280ee16;hb=c4d9561b1b35a0e8e594158fbb01a9c632997808;hpb=5f5747460a3330a1317395fedb60db33f6c00ab2

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 5510944dc..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,12 +98,7 @@ class QueryThread extends Thread implements SessionThread {
 	}
 
 	private boolean pumpTask() {
-		if(!processor.freeScheduling.isEmpty()) {
-			tasks.add(processor.freeScheduling.removeFirst());
-			processor.queueLength.decrementAndGet();
-			return true;
-		}
-		return false;
+	    return processor.scheduling.pumpTask(tasks);
 	}
 	
 	ArrayList<SessionTask> newTasks(boolean doWait, ArrayList<SessionTask> tasks) {
@@ -226,8 +221,6 @@ class QueryThread extends Thread implements SessionThread {
 	@Override
 	public void run() {
 
-		processor.thread.set(index);
-		
 		QuerySupport support = this.querySupport;
 
 		try {
@@ -242,23 +235,10 @@ class QueryThread extends Thread implements SessionThread {
 				while(!tasks.isEmpty()) {
 
 					SessionTask task = tasks.remove(tasks.size()-1);
-//					System.err.println("QT " + index + " runs " + task);
-					task.run(index);
+					task.run(0);
 
 				}
 
-//				for(int performer=0;performer<THREADS;performer++) {
-//					if(!delayQueues[index * THREADS + performer].isEmpty()) {
-//						synchronized(executors[performer]) {
-//							threadLocks[performer].lock();
-//							queues[performer].addAll(delayQueues[index * THREADS + performer]);
-//							delayQueues[index * THREADS + performer].clear();
-//							executors[performer].notify();
-//							threadLocks[performer].unlock();
-//						}
-//					}
-//				}
-
 			}
 
 		} catch (Throwable t) {