class ElasticAPM::Transport::Base

def ensure_worker_count
  @worker_mutex.synchronize do
    return if all_workers_alive?
    return if stopped.true?
    @workers.map! do |thread|
      next thread if thread&.alive?
      boot_worker
    end
  end
end