IdleQueue provide three distinct time based features. Uses select.poll()
|
|
|
|
|
set_alarm(self,
alarm_cb,
seconds)
Set up a new alarm. alarm_cb will be called after specified seconds. |
source code
|
|
|
remove_alarm(self,
alarm_cb,
alarm_time)
Remove alarm callback alarm_cb scheduled on alarm_time. Returns True if
it was removed sucessfully, otherwise False |
source code
|
|
|
|
|
set_read_timeout(self,
fd,
seconds,
func=None)
Seta a new timeout. If it is not removed after specified seconds,
func or obj.read_timeout() will be called |
source code
|
|
|
_check_time_events(self)
Execute and remove alarm callbacks and execute func() or read_timeout()
for plugged objects if specified time has ellapsed |
source code
|
|
|
plug_idle(self,
obj,
writable=True,
readable=True)
Plug an IdleObject into idlequeue. Filedescriptor fd must be set |
source code
|
|
|
|
|
|
|
|
|
|
|
|
|
process(self)
Process idlequeue. Check for any pending timeout or alarm events. Call
IdleObjects on possible and requested read, write and error events on
their file descriptors |
source code
|
|