Thread pool that dispatches consumer deliveries. Not supposed to be shared between channels or threads.
@private
# File lib/bunny/consumer_work_pool.rb, line 51 def join @threads.each { |t| t.join } end
# File lib/bunny/consumer_work_pool.rb, line 67 def kill @running = false @threads.each { |t| t.kill } end
# File lib/bunny/consumer_work_pool.rb, line 55 def pause @running = false @threads.each { |t| t.stop } end
# File lib/bunny/consumer_work_pool.rb, line 61 def resume @running = true @threads.each { |t| t.run } end
# File lib/bunny/consumer_work_pool.rb, line 37 def running? @running end
# File lib/bunny/consumer_work_pool.rb, line 41 def shutdown @running = false @size.times do submit do |*args| throw :terminate end end end
Generated with the Darkfish Rdoc Generator 2.