Timers

# File lib/timers.rb, line 11
def initialize
  @timers = SortedSet.new
end

# File lib/timers.rb, line 59
def add(timer)
  raise TypeError, "not a Timers::Timer" unless timer.is_a? Timers::Timer
  @timers.add(timer)
end

# File lib/timers.rb, line 16
def after(interval, &block)
  Timer.new(self, interval, false, &block)
end

# File lib/timers.rb, line 25
def after_milliseconds(interval, &block)
  after(interval / 1000.0, &block)
end

# File lib/timers.rb, line 31
def every(interval, &block)
  Timer.new(self, interval, true, &block)
end

# File lib/timers.rb, line 51
def fire(now = Time.now)
  time = now + 0.001 # Fudge 1ms in case of clock imprecision
  while (timer = @timers.first) && (time >= timer.time)
    @timers.delete timer
    timer.fire(now)
  end
end

# File lib/timers.rb, line 36
def wait
  i = wait_interval
  sleep i if i
  fire
end

# File lib/timers.rb, line 43
def wait_interval(now = Time.now)
  timer = @timers.first
  return unless timer
  interval = timer.time - now
  interval > 0 ? interval : 0
end