Rooba
/
pydle
mirror of https://github.com/Shizmob/pydle.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of github.com:Shizmob/pydle

This commit is contained in:
Tony Young 2014-02-16 19:03:23 +13:00
parent e30cc7fd2d 0693b1bb41
commit 43ff37f668
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pydle/async.py
View File

@ -4,6 +4,7 @@ import functools
import itertools import itertools
import collections import collections
import threading import threading
import datetime
import tornado.concurrent import tornado.concurrent
import tornado.ioloop import tornado.ioloop
@ -186,6 +187,9 @@ class EventLoop:
When called from within the event loop, will return an opaque handle that can be passed to `unschedule` When called from within the event loop, will return an opaque handle that can be passed to `unschedule`
to unschedule the function. to unschedule the function.
""" """
if not isinstance(_when, datetime.timedelta):
_when = datetime.timedelta(seconds=_when)
if self.run_thread != threading.current_thread().ident: if self.run_thread != threading.current_thread().ident:
# Schedule scheduling in IOLoop thread because of thread-safety. # Schedule scheduling in IOLoop thread because of thread-safety.
self.schedule(functools.partial(self._do_schedule_in, _when, _callback, _args, _kwargs)) self.schedule(functools.partial(self._do_schedule_in, _when, _callback, _args, _kwargs))
@ -199,6 +203,9 @@ class EventLoop:
to unschedule the first call of the function. to unschedule the first call of the function.
After that, a function will stop being scheduled if it returns False or raises an Exception. After that, a function will stop being scheduled if it returns False or raises an Exception.
""" """
if not isinstance(_interval, datetime.timedelta):
_interval = datetime.timedelta(seconds=_interval)
if self.run_thread != threading.current_thread().ident: if self.run_thread != threading.current_thread().ident:
# Schedule scheduling in IOLoop thread because of thread-safety. # Schedule scheduling in IOLoop thread because of thread-safety.
self.schedule(functools.partial(self._do_schedule_periodically, _interval, _callback, _args, _kwargs)) self.schedule(functools.partial(self._do_schedule_periodically, _interval, _callback, _args, _kwargs))