class Parapool::Worker

Public Class Methods

new(queue) click to toggle source
# File lib/parapool/worker.rb, line 5
def initialize(queue)
  raise TypeError, "wrong argument type #{queue.class} (expected Queue)" unless queue.is_a?(Queue)

  @queue = queue
end

Public Instance Methods

join() click to toggle source
# File lib/parapool/worker.rb, line 21
def join
  @thread.join
end
run() click to toggle source
# File lib/parapool/worker.rb, line 11
def run
  @thread = Thread.new do
    while job = @queue.pop do
      job.run
    end
  end

  self
end