Rufus::Scheduler::Job

# File lib/rufus/sc/jobs.rb, line 72
def initialize(scheduler, t, params, &block)

  @scheduler = scheduler
  @t = t
  @params = params
  @block = block || params[:schedulable]

  @running = false

  raise ArgumentError.new(
    'no block or :schedulable passed, nothing to schedule'
  ) unless @block

  @params[:tags] = Array(@params[:tags])

  @job_id = params[:job_id] || "#{self.class.name}_#{self.object_id.to_s}"

  determine_at
end

# File lib/rufus/sc/jobs.rb, line 94
def running

  @running
end

# File lib/rufus/sc/jobs.rb, line 119
def schedule_info

  @t
end

# File lib/rufus/sc/jobs.rb, line 103
def tags

  @params[:tags]
end

# File lib/rufus/sc/jobs.rb, line 111
def tags=(tags)

  @params[:tags] = Array(tags)
end

# File lib/rufus/sc/jobs.rb, line 126
def trigger(t=Time.now)

  @last = t
  job_thread = nil
  to_job = nil

  return if @running and (params[:allow_overlapping] == false)

  @running = true

  @scheduler.send(:trigger_job, @params) do
    #
    # Note that #trigger_job is protected, hence the #send
    # (Only jobs know about this method of the scheduler)

    job_thread = Thread.current
    job_thread[
      "rufus_scheduler__trigger_thread__#{@scheduler.object_id}"
    ] = true
    @last_job_thread = job_thread

    begin

      trigger_block

      job_thread = nil
      to_job.unschedule if to_job

    rescue Exception => e

      @scheduler.do_handle_exception(self, e)
    end

    @running = false
  end

  # note that add_job and add_cron_job ensured that :blocking is
  # not used along :timeout

  if to = @params[:timeout]

    to_job = @scheduler.in(to, :parent => self, :tags => 'timeout') do

      # at this point, @job_thread might be set

      if job_thread && job_thread.alive?
        job_thread.raise(Rufus::Scheduler::TimeOutError)
      end
    end
  end
end

# File lib/rufus/sc/jobs.rb, line 181
def trigger_block

  @block.respond_to?(:call) ?
    @block.call(self) : @block.trigger(@params.merge(:job => self))
end

# File lib/rufus/sc/jobs.rb, line 189
def unschedule

  @scheduler.unschedule(self.job_id)
end