Class: DatWorkerPool::Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/dat-worker-pool/worker.rb

Instance Method Summary collapse

Constructor Details

#initialize(pool, queue, workers_waiting, &block) ⇒ Worker

Returns a new instance of Worker.



7
8
9
10
11
12
13
14
 
# File 'lib/dat-worker-pool/worker.rb', line 7

def initialize(pool, queue, workers_waiting, &block)
  @pool            = pool
  @queue           = queue
  @workers_waiting = workers_waiting
  @block           = block
  @shutdown        = false
  @thread          = Thread.new{ work_loop }
end

Instance Method Details

#join(*args) ⇒ Object 



20
21
22
 
# File 'lib/dat-worker-pool/worker.rb', line 20

def join(*args)
  @thread.join(*args) if @thread
end

#shutdown ⇒ Object 



16
17
18
 
# File 'lib/dat-worker-pool/worker.rb', line 16

def shutdown
  @shutdown = true
end