thread queue example

thread_queue.rb

require "thread"
require "awesome_print"

start_time = Time.now

results = { body: [] }

queue = Queue.new

0..50.times { |x| queue.push x }

workers = (0..4).map do
  Thread.new do
    begin
      while record = queue.pop(true)
        # puts "Processing: #{record}"
        results[:body] << "Record #{record}"
        calc = record + 1
        results[:body] << "Results #{calc}"
      end
    rescue ThreadError
    end
  end
end

workers.map(&:join)

end_time = Time.now

total_time = (end_time - start_time) / 60

puts workers
ap results[:body]
puts total_time