class Concurrent::CyclicBarrier

def ns_generation_done(generation, status, continue = true)
  generation.status = status
  ns_next_generation if continue
  ns_broadcast
end