Contents

module Workers
  class Timer
    include Workers::Helpers

    attr_reader :delay
    attr_reader :repeat

    def initialize(delay, options = {}, &block)
      @logger = Workers::LogProxy.new(options[:logger])
      @delay = delay
      @callback = options[:callback] || block
      @repeat = options[:repeat] || false
      @scheduler = options[:scheduler] || Workers.scheduler
      @mutex = Mutex.new

      reset
      @scheduler.schedule(self)

      nil
    end

    def <=>(other)
      sec_remaining <=> other.sec_remaining
    end

    def sec_remaining
      @mutex.synchronize do
        diff = @fire_at.to_f - Time.now.utc.to_f
        (diff > 0) ? diff : 0
      end
    end

    def overdue?
      sec_remaining <= 0
    end

    def fire
      @mutex.synchronize do
        @callback.call if @callback
      end

      nil
    end

    def cancel
      @scheduler.unschedule(self)

      nil
    end

    def reset
      @mutex.synchronize do
        @fire_at = Time.now.utc + @delay
      end

      nil
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
workers-0.6.1	lib/workers/timer.rb
workers-0.6.0	lib/workers/timer.rb
workers-0.5.0	lib/workers/timer.rb
workers-0.4.0	lib/workers/timer.rb