class Concurrent::IVar

def notify_observers(value, reason)
  observers.notify_and_delete_observers{ [Time.now, value, reason] }
end