diff options
| -rw-r--r-- | src/database/BrandAnalyzerQueue.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/database/BrandAnalyzerQueue.java b/src/database/BrandAnalyzerQueue.java index f6b0a40..af5ba7c 100644 --- a/src/database/BrandAnalyzerQueue.java +++ b/src/database/BrandAnalyzerQueue.java @@ -42,7 +42,10 @@ public class BrandAnalyzerQueue implements Runnable { } try { last = true; - queue.put(new Result(-1, null)); + // for each concurrent worker, there must be at least one killer + for (int i = 0; i < 16; i++) { + queue.put(new Result(-1, null)); + } } catch (InterruptedException ex) { getLogger().log(Level.SEVERE, "Failed to insert suicide pill!"); } |