Module: Clockwork
Defined Under Namespace
Classes: At, Event, NoHandlerDefined
Constant Summary
collapse
- @@events =
[]
Instance Method Summary
collapse
Instance Method Details
#clear! ⇒ Object
145
146
147
148
|
# File 'lib/clockwork.rb', line 145
def clear!
@@events = []
@@handler = nil
end
|
#every(period, job, options = {}, &block) ⇒ Object
108
109
110
111
112
113
114
115
116
117
118
|
# File 'lib/clockwork.rb', line 108
def every(period, job, options={}, &block)
if options[:at].respond_to?(:each)
each_options = options.clone
options[:at].each do |at|
each_options[:at] = at
register(period, job, block, each_options)
end
else
register(period, job, block, options)
end
end
|
#get_handler ⇒ Object
103
104
105
106
|
# File 'lib/clockwork.rb', line 103
def get_handler
raise NoHandlerDefined unless (defined?(@@handler) and @@handler)
@@handler
end
|
#handler(&block) ⇒ Object
97
98
99
|
# File 'lib/clockwork.rb', line 97
def handler(&block)
@@handler = block
end
|
#log(msg) ⇒ Object
128
129
130
|
# File 'lib/clockwork.rb', line 128
def log(msg)
puts msg
end
|
#run ⇒ Object
120
121
122
123
124
125
126
|
# File 'lib/clockwork.rb', line 120
def run
log "Starting clock for #{@@events.size} events: [ " + @@events.map { |e| e.to_s }.join(' ') + " ]"
loop do
tick
sleep 1
end
end
|
#tick(t = Time.now) ⇒ Object
132
133
134
135
136
137
138
139
140
141
142
143
|
# File 'lib/clockwork.rb', line 132
def tick(t=Time.now)
to_run = @@events.select do |event|
event.time?(t)
end
to_run.each do |event|
log "Triggering #{event}"
event.run(t)
end
to_run
end
|