Contents

# a job is not necessarily registered with job control.
class Rubish::Job
  class Failure < Rubish::Error
    attr_reader :job, :reason
    def initialize(job,reason=nil)
      raise "failure reason should be an Exception" unless reason.is_a?(Exception)
      @job = job
      @reason = reason
      set_backtrace(reason.backtrace)
    end

    def to_s
      @reason.to_s
    end
  end

  attr_accessor :result
  attr_reader :job_control

  # subclass initializer MUST call __start
  def initialize(*args)
    raise "abstract"
    __start
  end

  def __start
    @result = nil
    @done = false
    # when wait is called, the job control may or
    # may not be the current job_control.
    @job_control = Rubish::JobControl.current 
    @job_control.submit(self)
    self
  end

  def __finish
    @job_control.remove(self)
    @done = true
    self
  end

  # MUST call __finish in wait
  # should return Job#result
  def wait
    raise "abstract"
    __finish
  end

  # MUST result in calling __finish
  def stop
    raise "abstract"
  end

  def done?
    @done
  end
  
end

# carry out some computation in a thread.
class Rubish::Job::ThreadJob < Rubish::Job
  attr_reader :thread
  def initialize(&block)
    # run block in a thread
    @thread = ::Thread.new {
      block.call
    }
    __start
  end

  def wait
    # wait thread to completeggg64
    begin
      @thread.join
      @result = @thread.value
      return self.result
    rescue => e
      raise Rubish::Job::Failure.new(self,e)
    ensure
      __finish
    end
  end

  def stop
    @thread.kill
    wait
  end
  
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rubish-0.1.0	lib/rubish/job.rb
rubish-0.0.1	lib/rubish/job.rb