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:
parent
a1f3ccdd6d
commit
ba8a75c84b
@ -38,7 +38,7 @@ public class ProcessingIterator<T> implements Iterator<T> {
|
||||
|
||||
private void executeJob(ProcessingJob<T> job) {
|
||||
try {
|
||||
job.run(j -> executorService.submit(() -> executeTask(j)));
|
||||
job.run(this::executeTask);
|
||||
} catch (Exception e) {
|
||||
logger.warn("Exception while processing", e);
|
||||
} finally {
|
||||
@ -53,6 +53,7 @@ public class ProcessingIterator<T> implements Iterator<T> {
|
||||
return;
|
||||
}
|
||||
|
||||
executorService.submit(() -> {
|
||||
try {
|
||||
queue.put(task.get());
|
||||
} catch (Exception e) {
|
||||
@ -60,6 +61,7 @@ public class ProcessingIterator<T> implements Iterator<T> {
|
||||
} finally {
|
||||
sem.release();
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
/** Returns true if there are more documents to be processed.
|
||||
|
Loading…
Reference in New Issue
Block a user