gistfile1.groovy

def moagents = (swarm as PreSchedulingSwarm).swarmContext.preschedulingStorage.movingObjectAgents;

moagents.each {
  swarm.parallelExecutionService.submit(normalizeClosure(it));
}
while (normalizeCounter.get() < moagents.size()) {}
changed |= normalizeOccured.get()

moagents.each {
  swarm.parallelExecutionService.submit(closeUpClosure(it, true));
}
while (closeUpCounter.get() < moagents.size()){}
changed |= closeUpOccured.get();

changed |= PreschedulerUtils.closeUpAllStations(swarm.swarmContext);