class Concurrent::UnbufferedChannel

def remove_probe(probe)

def remove_probe(probe)
  @probe_set.delete(probe)
end