Contents

module ActiveJob
  module Cron
    class Clock
      include Celluloid
      include Loggable
      attr_reader :schedules

      def initialize # :nodoc:
        super
        after(1) do
          loop!
        end
      end

      # Get the schedule for `job`.
      def schedule_for(job)
        if job.respond_to?(:schedule)
          job.schedule
        end
      end

      # Tick a single clock.
      def tick(time = gettime)
        ActiveJob::Cron.jobs.each do |job|
          ActiveJob::Cron.handler.dispatch(job, time)
        end
      end

      # Returns the current time used by the clock.
      def gettime
        ActiveJob::Cron.config.utc ? Time.now.utc : Time.now
      end

      private

      def loop!
        after([time { tick }, 0].max) do
          loop!
        end
      rescue StandardError => e
        raise e
      end

      def time
        start = gettime
        yield
        ActiveJob::Cron.config.resolution - (gettime.to_f - start.to_f)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
active_job-cron-0.1.0	lib/active_job/cron/clock.rb