class Concurrent::Supervisor

def remove_worker(worker_id)
  @mutex.synchronize do
    index, context = find_worker(worker_id)
    break(nil) if context.nil?
    break(false) if context.alive?
    @workers.delete_at(index)
    context.worker
  end
end