concurrency_ruby_threads.rb

require 'thread'
require_relative 'add_one_task'
scheduled = []; performed = []; producers = []; consumers = []
5.times do
  producers << Thread.new do
    scheduled.push AddOneTask.new
  end
end
5.times do
  consumers << Thread.new do
    loop do
      task = scheduled.pop
      performed << task.perform unless task.nil?
      break if scheduled.empty?
    end
  end
end
(producers + consumers).each { |t| t.join }