This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
事件循环实现- kombu.asynchronous.hub
¶
事件循环实现。
- class kombu.asynchronous.hub.Hub(timer=None)[源代码]¶
事件循环对象。
论点:¶
Timer(kombu.asynous.Timer):指定自定义的Timer实例。
- ERR = 24¶
错误时设置标志,且应从AAP读取FD。
- READ = 1¶
如果从FD读取不会阻止,则设置标志。
- WRITE = 4¶
如果写入FD不会阻止,则设置标志。
- create_loop(generator=<class 'generator'>, sleep=<built-in function sleep>, min=<built-in function min>, next=<built-in function next>, Empty=<class '_queue.Empty'>, StopIteration=<class 'StopIteration'>, KeyError=<class 'KeyError'>, READ=1, WRITE=4, ERR=24)[源代码]¶
- property loop¶
- on_close = None¶
循环退出时要调用的回调列表,以集线器实例作为唯一参数应用。
- property poller¶
- property scheduler¶