Sha256: 901d1ce23f78113bff89c1a3b6350d9d491077b31d375976162791fdd8ea19fc
Contents?: true
Size: 764 Bytes
Versions: 17
Compression:
Stored size: 764 Bytes
Contents
require 'monitor'
module Rpush
module Daemon
class InterruptibleSleep
def initialize(duration)
@duration = duration
@obj = Object.new
@obj.extend(MonitorMixin)
@condition = @obj.new_cond
@stop = false
end
def sleep
return if @stop
@obj.synchronize { @condition.wait(100_000) }
end
def start
@stop = false
@thread = Thread.new do
loop do
break if @stop
Kernel.sleep(@duration)
wakeup
end
end
end
def stop
@stop = true
wakeup
@thread.kill if @thread
end
def wakeup
@obj.synchronize { @condition.signal }
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems