Module that helps to spread collection job to all available workers

workers_balancer.rb

# frozen_string_literal: true

module WorkersBalancer
  def self.included(base)
    base.extend ClassMethods
  end

  module ClassMethods
    def balanced_perform_later(collection_ids)
      collection_ids.in_groups(workers_count).each do |ids_group|
        perform_later(ids_group)
      end
    end

    def workers_count
      Resque.workers.any? ? Resque.workers.count : 1
    end
  end
end