From aeff31cd445cd2d3683f0f4bf25a41e04ec403f3 Mon Sep 17 00:00:00 2001
From: orbiter <mc@yacy.net>
Date: Sun, 12 May 2013 21:36:20 +0200
Subject: [PATCH] fix for workflow processor (cause: latest redesign for less
 threads)

---
 source/net/yacy/kelondro/workflow/WorkflowProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/net/yacy/kelondro/workflow/WorkflowProcessor.java b/source/net/yacy/kelondro/workflow/WorkflowProcessor.java
index d3fe0d361..296892f58 100644
--- a/source/net/yacy/kelondro/workflow/WorkflowProcessor.java
+++ b/source/net/yacy/kelondro/workflow/WorkflowProcessor.java
@@ -177,13 +177,13 @@ public class WorkflowProcessor<J extends WorkflowJob> {
         // execute concurrent in thread
         while (this.input != null) {
             try {
+                this.input.put(in);
                 if (this.input.size() > this.executorRunning.get() && this.executorRunning.get() < this.maxpoolsize) synchronized (executor) {
                     if (this.input.size() > this.executorRunning.get() && this.executorRunning.get() < this.maxpoolsize) {
                         this.executorRunning.incrementAndGet();
                         this.executor.submit(new InstantBlockingThread<J>(this));
                     }
                 }
-                this.input.put(in);
                 break;
             } catch (final Throwable e) {
                 try {Thread.sleep(10);} catch (final InterruptedException ee) {}