Method: Aws::Xray::Worker.reset

Defined in:
lib/aws/xray/worker.rb

.reset(config) ⇒ Object

Parameters:



30
31
32
33
34
 
# File 'lib/aws/xray/worker.rb', line 30

def reset(config)
  @queue = Thread::SizedQueue.new(config.max_queue_size)
  @workers.each(&:kill) if defined?(@workers) && !@workers.empty?
  @workers = Array.new(config.num) { new(@queue).run }
end