vendor/bundle/ruby/1.8/gems/work_queue-1.0.0/lib/work_queue.rb
def work
    loop do
      begin
        proc, args = timeout(keep_alive) { @tasks.pop }
        proc.call(*args)
      rescue Timeout::Error
        break
      rescue Exception
        # suppress exception
      end
      break if cur_threads > max_threads
    end
  end
##
# Repeatedly process the tasks queue.
#
Repeatedly process the tasks queue.
Repeatedly process the tasks queue .
def work
    loop do
      begin
        proc, args = timeout(keep_alive) { @tasks.pop }
        proc.call(*args)
      rescue Timeout::Error
        break
      rescue Exception
      end
      break if cur_threads > max_threads
    end
  end
def work loop do begin proc , args = timeout ( keep_alive ) { @tasks . pop } proc . call ( * args ) rescue Timeout :: Error break rescue Exception end break if cur_threads > max_threads end end
Repeatedly process the tasks queue.
Repeatedly process the tasks queue .
# suppress exception