Bulk push of jobs about faktory_worker_ruby HOT 1 OPEN

require 'faktory'
require 'thread'
require 'securerandom'

ids = (1..1000).to_a
q = Queue.new 
ids.each_slice(10).to_a.each {|m| q.push([m[0], m[-1]]) }
q.close

threads = []
10.times do |idx|
  job = { "jobtype": "SomeWorker", "queue": "default"  }
  threads << Thread.new do
    c = Faktory::Client.new(debug: true)
    while args = q.pop
      c.push(job.merge("args": q.pop, "jid": SecureRandom.hex(8)))
    end
    c.close
  end
end

threads.each(&:join)