utils.timer2

Scheduler for Python functions.

Note

This is used for the thread-based worker only, not for amqp/redis/sqs/qpid where kombu.asynchronous.timer is used.

Module Contents

Classes

Timer(self,schedule=None,on_error=None,on_tick=None,on_start=None,max_interval=None,**kwargs) Timer thread.
class Timer(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)

Timer thread.

Note:
This is only used for transports not supporting AsyncIO.
start(*args, **kwargs)
__init__(schedule=None, on_error=None, on_tick=None, on_start=None, max_interval=None, **kwargs)
_next_entry()
run()
stop()
ensure_started()
_do_enter(meth, *args, **kwargs)
enter(entry, eta, priority=None)
call_at(*args, **kwargs)
enter_after(*args, **kwargs)
call_after(*args, **kwargs)
call_repeatedly(*args, **kwargs)
exit_after(secs, priority=10)
cancel(tref)
clear()
empty()
__len__()
__bool__()

bool(timer).

queue()