class Concurrent::CyclicBarrier

def ns_initialize(parties, &block)

def ns_initialize(parties, &block)
  @parties = parties
  @action  = block
  ns_next_generation
end