Contents

module God
  
  class TimerEvent
    attr_accessor :watch, :condition, :command, :at
    
    def initialize(watch, condition, command)
      self.watch = watch
      self.condition = condition
      self.command = command
      self.at = Time.now.to_i + condition.interval
    end
  end
  
  class Timer < Base
    INTERVAL = 0.25
    
    attr_reader :events
    
    # Start the scheduler loop to handle events
    def initialize
      @events = []
      
      @timer = Thread.new do
        loop do
          # get the current time
          t = Time.now.to_i
          
          # iterate over each event and trigger any that are due
          @events.each do |event|
            if t >= event.at
              self.trigger(event)
              @events.delete(event)
            else
              break
            end
          end
          
          # sleep until next check
          sleep INTERVAL
        end
      end
    end
    
    # Create and register a new TimerEvent with the given parameters
    def register(watch, condition, command)
      @events << TimerEvent.new(watch, condition, command)
      @events.sort! { |x, y| x.at <=> y.at }
    end
    
    def trigger(event)
      timer = self
      
      Thread.new do
        w = event.watch
        c = event.condition
        
        w.mutex.synchronize do
          if c.test
            puts w.name + ' ' + c.class.name + ' [ok]'
          else
            puts w.name + ' ' + c.class.name + ' [fail]'
            c.after
            w.action(event.command, c)
          end
        end
        
        # reschedule
        timer.register(w, c, event.command)
      end
    end
    
    # Join the timer thread
    def join
      @timer.join
    end
  end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
god-0.1.0	lib/god/timer.rb