Fix bug in ProcessingIterator where it would run the tasks in only one single thread instead of using the pool

This commit is contained in:
Viktor Lofgren 2023-12-29 14:59:39 +01:00
parent 647d38007f
commit a1f3ccdd6d

View File

@ -38,7 +38,7 @@ public class ProcessingIterator<T> implements Iterator<T> {
private void executeJob(ProcessingJob<T> job) {
try {
job.run(this::executeTask);
job.run(j -> executorService.submit(() -> executeTask(j)));
} catch (Exception e) {
logger.warn("Exception while processing", e);
} finally {