3 # timer event, something to do and when/how often to do it
6 # when this action is due next (updated by tick())
9 # is this action blocked? if so it won't be run
10 attr_accessor :blocked
12 # period:: how often (seconds) to run the action
13 # data:: optional data to pass to the proc
14 # once:: optional, if true, this action will be run once then removed
15 # func:: associate a block to be called to perform the action
18 def initialize(period, data=nil, once=false, &func)
29 diff = Time.new - @last_tick
35 "#<#{self.class}:#{@period}s:#{@once ? 'once' : 'repeat'}>"
42 # run the action by calling its proc
45 # really short duration timers can overrun and leave @in negative,
46 # for these we set @in to @period
47 @in = @period if @in <= 0
56 # reschedule the Action to change its period
57 def reschedule(new_period)
63 # timer handler, manage multiple Action objects, calling them when required.
64 # The timer must be ticked by whatever controls it, i.e. regular calls to
65 # tick() at whatever granularity suits your application's needs.
67 # Alternatively you can call run(), and the timer will spawn a thread and
68 # tick itself, intelligently shutting down the thread if there are no
71 def initialize(granularity = 0.1)
72 @granularity = granularity
76 @should_be_running = false
81 # period:: how often (seconds) to run the action
82 # data:: optional data to pass to the action's proc
83 # func:: associate a block with add() to perform the action
85 # add an action to the timer
86 def add(period, data=nil, &func)
87 debug "adding timer, period #{period}"
89 @timers[@handle] = Action.new(period, data, &func)
94 # period:: how long (seconds) until the action is run
95 # data:: optional data to pass to the action's proc
96 # func:: associate a block with add() to perform the action
98 # add an action to the timer which will be run just once, after +period+
99 def add_once(period, data=nil, &func)
100 debug "adding one-off timer, period #{period}"
102 @timers[@handle] = Action.new(period, data, true, &func)
107 # remove action with handle +handle+ from the timer
109 @timers.delete(handle)
112 # block action with handle +handle+
114 @timers[handle].blocked = true
117 # unblock action with handle +handle+
119 @timers[handle].blocked = false
122 # reschedule action with handle +handle+ to change its period
123 def reschedule(handle, period)
124 @timers[handle].reschedule(period)
127 # you can call this when you know you're idle, or you can split off a
128 # thread and call the run() method to do it for you.
131 # don't do anything on the first tick
135 @next_action_time = 0
136 diff = (Time.now - @lasttime).to_f
138 @timers.each { |key,timer|
140 next if timer.blocked
147 if @next_action_time == 0 || timer.in < @next_action_time
148 @next_action_time = timer.in
151 #debug "ticked. now #{@timers.length} timers remain"
152 #debug "next timer due at #{@next_action_time}"
155 # for backwards compat - this is a bit primitive
156 def run(granularity=0.1)
164 @thread && @thread.alive?
167 # return the number of seconds until the next action is due, or 0 if
168 # none are outstanding - will only be accurate immediately after a
174 # start the timer, it spawns a thread to tick the timer, intelligently
175 # shutting down if no events remain and starting again when needed.
178 @should_be_running = true
179 start_thread unless @timers.empty?
182 # stop the timer from ticking
184 @should_be_running = false
194 elsif @should_be_running
200 return unless running?
206 @thread = Thread.new do
209 exit if @timers.empty?
210 sleep(@next_action_time)