nojhan/weboob-devel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

the first repeated task is run in a thread too

Browse source
This commit is contained in:
Romain Bignon 2010-05-20 19:50:15 +02:00
commit 6f1cec035d
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
weboob/scheduler.py
View file

@ -43,6 +43,9 @@ class Scheduler(IScheduler):
self.queue = {} self.queue = {}
def schedule(self, interval, function, *args): def schedule(self, interval, function, *args):
if self.stop_event.isSet():
return
self.count += 1 self.count += 1
logging.debug('function "%s" will be called in %s seconds' % (function.__name__, interval)) logging.debug('function "%s" will be called in %s seconds' % (function.__name__, interval))
timer = Timer(interval, function, args) timer = Timer(interval, function, args)
@ -51,11 +54,10 @@ class Scheduler(IScheduler):
return self.count return self.count
def repeat(self, interval, function, *args): def repeat(self, interval, function, *args):
if self.stop_event.isSet(): return self._repeat(True, interval, function, *args)
return
function(*args) def _repeat(self, first, interval, function, *args):
return self.schedule(interval, self._repeated_cb, interval, function, args) return self.schedule(0 if first else interval, self._repeated_cb, interval, function, args)
def _wait_to_stop(self): def _wait_to_stop(self):
self.want_stop() self.want_stop()
@ -78,4 +80,5 @@ class Scheduler(IScheduler):
self.stop_event.set() self.stop_event.set()
def _repeated_cb(self, interval, function, args): def _repeated_cb(self, interval, function, args):
self.repeat(interval, function, *args) function(*args)
self._repeat(False, interval, function, *args)