lib/thread/every.rb in thread-0.1.7 vs lib/thread/every.rb in thread-0.2.0
- old
+ new
@@ -16,11 +16,11 @@
class Thread::Every
Cancel = Class.new(Exception)
Restart = Class.new(Exception)
# Create an every with the given seconds and block.
- def initialize (every, &block)
+ def initialize(every, &block)
raise ArgumentError, 'no block given' unless block
@every = every
@old = true
@mutex = Mutex.new
@@ -65,18 +65,18 @@
ObjectSpace.define_finalizer self, self.class.finalizer(@thread)
end
# @private
- def self.finalizer (thread)
+ def self.finalizer(thread)
proc {
thread.raise Cancel.new
}
end
# Change the number of seconds between each call.
- def every (seconds)
+ def every(seconds)
@every = seconds
restart
end
@@ -142,11 +142,11 @@
@every - (Time.now - @at)
}
end
# Gets the current every value.
- def value (timeout = nil)
+ def value(timeout = nil)
@mutex.synchronize {
if @old
cond.wait(@mutex, *timeout)
end
@@ -170,11 +170,11 @@
@value unless @exception
}
end
- private
+private
def cond?
instance_variable_defined? :@cond
end
def cond
@@ -182,16 +182,16 @@
end
end
class Thread
# Helper to create an every
- def self.every (every, &block)
+ def self.every(every, &block)
Thread::Every.new(every, &block)
end
end
module Kernel
# Helper to create an every
- def every (every, &block)
+ def every(every, &block)
Thread::Every.new(every, &block)
end
end