Fiber Creation

fiber.rb

#!/usr/bin/env ruby
#Thread.abort_on_exception = true
 
require 'fiber'
require 'benchmark'

class FiberRing
  attr_reader :id
  def initialize(id)
    @id = id
    @fiber = Fiber.new do
      pass_msg
    end
  end

  def |(nxt)
    @next = nxt
    nxt
  end

  def resume
    # puts "@fiber: #{@fiber}"
    @fiber.resume
  end

  def pass_msg
    while msg = msg_in
      msg_out msg
    end
  end

  def msg_in
    unless @next.nil?
      @next.resume
    end
    "#{@id} message"
  end

  def msg_out msg
    Fiber.yield msg
  end
end


n = 10000
m = 1
puts "#{n}, #{m}:"
tm = Benchmark.bmbm do |bm|

  3.times do
    bm.report{
      f0 = f = FiberRing.new(0)
      t = Time.now
      1.upto(n-1) { |i| f = (f | FiberRing.new(i)) }
      puts "Creation: #{Time.now - t}"
      
      t = Time.now
      m.times { |j| f0.resume }
      puts "Execution: #{Time.now - t}"
    }
  end
end