class Resque::ThreadSignal

Public Instance Methods

signal() click to toggle source
# File lib/resque/thread_signal.rb, line 7
def signal
  @signaled = true
end
wait_for_signal(timeout) click to toggle source
# File lib/resque/thread_signal.rb, line 11
def wait_for_signal(timeout)
  (10 * timeout).times do
    sleep(0.1)
    return true if @signaled
  end

  @signaled
end

Public Class Methods

new() click to toggle source
# File lib/resque/thread_signal.rb, line 3
def initialize
  @signaled = false
end