in src/main/java/org/apache/maven/plugins/invoker/JobExecutor.java [50:82]
public void forEach(ThrowableJobConsumer jobConsumer) {
// group and sort jobs by ordinal
Map<Integer, List<BuildJob>> groupedJobs = jobs.stream()
.sorted(Comparator.comparing(BuildJob::getOrdinal).reversed())
.collect(Collectors.groupingBy(BuildJob::getOrdinal, LinkedHashMap::new, Collectors.toList()));
ExecutorService executorService = Executors.newFixedThreadPool(threadsCount);
groupedJobs.forEach((key, value) -> {
// prepare list of callable tasks
List<Callable<Void>> callableJobs = value.stream()
.map(buildJob -> (Callable<Void>) () -> {
try {
jobConsumer.accept(buildJob);
} catch (Throwable e) {
buildJob.setResult(BuildJob.Result.ERROR);
buildJob.setFailureMessage(String.valueOf(e));
}
return null;
})
.collect(Collectors.toList());
try {
executorService.invokeAll(callableJobs);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
}
});
// all task are finished here
executorService.shutdownNow();
}