Method: Oxidized::Worker#initialize

Defined in:
lib/oxidized/worker.rb

#initialize(nodes) ⇒ Worker

Returns a new instance of Worker.



5
6
7
8
9
10
11
# File 'lib/oxidized/worker.rb', line 5

def initialize(nodes)
  @jobs_done  = 0
  @nodes      = nodes
  @jobs       = Jobs.new(Oxidized.config.threads, Oxidized.config.use_max_threads, Oxidized.config.interval, @nodes)
  @nodes.jobs = @jobs
  Thread.abort_on_exception = true
end