in src/main/java/com/googlesource/gerrit/plugins/renameproject/database/IndexUpdateHandler.java [49:68]
public void updateIndex(
List<Change.Id> changeIds, Project.NameKey newProjectKey, Optional<ProgressMonitor> opm)
throws InterruptedException {
log.debug("Starting to index {} change(s).", changeIds.size());
ExecutorService executor =
Executors.newFixedThreadPool(
config.getIndexThreads(),
new ThreadFactoryBuilder().setNameFormat("Rename-Index-%d").build());
opm.ifPresent(pm -> pm.beginTask("Indexing changes", changeIds.size()));
List<Callable<Boolean>> callableTasks = new ArrayList<>(changeIds.size());
for (Change.Id id : changeIds) {
callableTasks.add(new IndexTask(id, newProjectKey, opm));
}
List<Future<Boolean>> tasksCompleted = executor.invokeAll(callableTasks);
executor.shutdown();
if (verifyAllTasksCompleted(tasksCompleted)) {
log.debug("Indexed {} change(s) successfully.", changeIds.size());
}
}