Contents

# based on Timeout

module ContiniousTimeout
  class TimeoutException < ::Exception
  end

  class RestartException < ::Exception
  end

  class Deferer
    def initialize(thread)
      @thread = thread
    end

    def defer
      @thread.raise RestartException.new
    end
  end

  def self.timeout(sec)
    begin
      x = Thread.current
      y = Thread.start do
        1.times do
          begin
            sleep sec
          rescue RestartException => e
            retry
          end
        end
        x.raise TimeoutException, "execution expired" if x.alive?
      end
      yield Deferer.new(y)
    ensure
      y.kill if y and y.alive?
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
dump-1.0.4	lib/dump_rake/continious_timeout.rb
dump-1.0.3	lib/dump_rake/continious_timeout.rb
dump-1.0.2	lib/dump_rake/continious_timeout.rb
dump-1.0.1	lib/dump_rake/continious_timeout.rb
dump-1.0.0	lib/dump_rake/continious_timeout.rb