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