class Concurrent::Synchronization::Condition

def broadcast

def broadcast
  @Lock.synchronize { ns_broadcast }
end