Ruby Each in Thread implementation - each_in_thread - Good for concurrent API calls.

each_in_thread.rb

# frozen_string_literal: true

require 'thread/pool'

# Install Gem 'thread' or add it to your Gemfile.
#
# Example:
#
# ids = [1,2,3,4,5,6,7,8,9,10]
# ids.each_in_thread(concurrency: 20) do |id|
#   Http.put("https://api.example.items/#{id}", {updated: true})
# end

module Enumerable
  def each_in_thread(concurrency: 10, count_each: 1)
    pool = Thread.pool(concurrency)
    done = 0

    self.each_with_index do |item, i|
      pool.process do
        yield item, i
        print "completed #{done} / #{self.size}\r" if (done += 1) % count_each == 0
      end
    end

    pool.shutdown
  end
end