Simple multi-threading processing in ruby

multi-threading.rb

results = []

queue = Queue.new
mutex = Mutex.new

THREAD_COUNT = 3

threads = Array.new(THREAD_COUNT) do
  Thread.new do
    while (value = queue.pop)
      mutex.synchronize do
        sleep 0.01
        results << value + 1
      end
    end
  end
end

100.times do
  queue << rand(100)
end

queue.close # queue.pop will return `nil` once the queue is empty
threads.each(&:join) # wait for all threads to finish

pp results