This commit is contained in:
Alexey Kudravtsev
2015-11-03 14:29:35 +03:00
parent 745c44ff15
commit de8dadeee2
@@ -297,7 +297,8 @@ public class JobLauncherImpl extends JobLauncher {
}
/**
* Process all elements from the {@code failedToProcess} and then {@code things} concurrently in the underlying pool maintaining its load.
* Process all elements from the {@code failedToProcess} and then {@code things} concurrently in the underlying pool.
* Processing happens concurrently maintaining {@code JobSchedulerImpl.CORES_COUNT} parallelism.
* Stop when {@code tombStone} element is occurred.
* If was unable to process some element, add it back to the {@code failedToProcess} queue.
* @return true if all elements processed successfully, false if at least one processor returned false or exception occurred