diff --git a/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java b/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java index 15dbc087..edcc038a 100644 --- a/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java +++ b/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java @@ -75,7 +75,7 @@ public class ProcessingIterator implements Iterator { return true; do { - next = queue.poll(1, TimeUnit.SECONDS); + next = queue.poll(50, TimeUnit.MILLISECONDS); if (next != null) { return true; }