Thread pool that dispatches consumer deliveries. Not supposed to be shared between channels or threads.
Every channel its own consumer pool.
@private
# File lib/bunny/consumer_work_pool.rb, line 54 def join(timeout = nil) @threads.each { |t| t.join(timeout) } end
# File lib/bunny/consumer_work_pool.rb, line 70 def kill @running = false @threads.each { |t| t.kill } end
# File lib/bunny/consumer_work_pool.rb, line 58 def pause @running = false @threads.each { |t| t.stop } end
# File lib/bunny/consumer_work_pool.rb, line 64 def resume @running = true @threads.each { |t| t.run } end
# File lib/bunny/consumer_work_pool.rb, line 40 def running? @running end
# File lib/bunny/consumer_work_pool.rb, line 44 def shutdown @running = false @size.times do submit do |*args| throw :terminate end end end
Generated with the Darkfish Rdoc Generator 2.