class Concurrent::CopyOnWriteObserverSet

def observers=(new_set)

def observers=(new_set)
  @mutex.synchronize { @observers = new_set}
end