Example of queuing up 100 workloads per task

batching_queue.rb

users = User.all
users_for_worker = []
users.each_with_index do |user, i|
  # Queue up a task every 100
  if i > 0 && i % 100 == 0 
    puts "#{i} Queueing worker..."
    worker = NotificationWorker.new
    worker.users = users_for_worker
    # set other attributes that your worker needs to run
    worker.queue
    users_for_worker = []
  end
  users_for_worker << user
end

User.find_in_batches(100) do |users_for_worker|
  puts 'Queuing worker'
  worker = NotificationWorker.new
  worker.users = users_for_worker
  worker.queue
end

Much nicer @jakeonrails . ;) Thanks.