From a1f3ccdd6d2283c5510aa11ded39d677803a1066 Mon Sep 17 00:00:00 2001 From: Viktor Lofgren Date: Fri, 29 Dec 2023 14:59:39 +0100 Subject: [PATCH] Fix bug in ProcessingIterator where it would run the tasks in only one single thread instead of using the pool --- .../src/main/java/nu/marginalia/util/ProcessingIterator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 edcc038a..08459b76 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 @@ -38,7 +38,7 @@ public class ProcessingIterator implements Iterator { private void executeJob(ProcessingJob job) { try { - job.run(this::executeTask); + job.run(j -> executorService.submit(() -> executeTask(j))); } catch (Exception e) { logger.warn("Exception while processing", e); } finally {