concurrency_ruby_fibers.rb

require 'fiber'
require_relative 'add_one_task'
scheduled = []; performed = []
consumers = []; scheduler = nil
producer = Fiber.new do
  5.times do
    scheduled.push AddOneTask.new
    scheduler.transfer
  end
end
5.times do
  consumers << Fiber.new do
    task = scheduled.pop
    performed << task.perform unless task.nil?
    Fiber.yield
  end
end
scheduler = Fiber.new do
  consumers.each do |c|
    c.resume
    producer.transfer
  end
end
producer.resume