thread_pool

Emad Elsaid · @emad-elsaid · about 4 years

def thread_pool(objects:, method:, pool_size:)
  queue = Queue.new
  objects.each { |obj| queue << obj }

  (0...pool_size).map do 
    Thread.new do
        while object = queue.pop(true)
        begin
          puts "Executing: #{object}#.#{method}"
          object.send(method)
        rescue StandardError => e
          puts "Error processing #{object} #{e}"
        end
      end
    rescue ThreadError
      true
    end
  end.map(&:join)

end