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 { // 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(this)); } } - this.input.put(in); break; } catch (final Throwable e) { try {Thread.sleep(10);} catch (final InterruptedException ee) {}