153154155156157158159160161162163
}; workers.add(edgeWorker); // blocks until all Callables are done running. parallelizer.invokeAllRunnables(workers); prof.stopConcurrentCalculationTime(); prof.startCommitChangesTime(); model_.commitChanges(); prof.stopCommitChangesTime();