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不会阻止，则设置标志。

add(fd, callback, flags, args=(), consolidate=False)

add_reader(fds, callback, *args)

add_writer(fds, callback, *args)

call_at(when, callback, *args)

call_later(delay, callback, *args)

call_repeatedly(delay, callback, *args)

call_soon(callback, *args)

close(*args)

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)

fire_timers(min_delay=1, max_delay=10, max_timers=10, propagate=())

property loop

on_callback_error(callback, exc)

on_close = None

循环退出时要调用的回调列表，以集线器实例作为唯一参数应用。

property poller

remove(fd)

remove_reader(fd)

remove_writer(fd)

repr_active()

repr_events(events)

reset()

run_forever()

run_once()

property scheduler

stop()

kombu.asynchronous.hub.get_event_loop() → Hub | None

获取当前事件循环对象。

kombu.asynchronous.hub.set_event_loop(loop: Hub | None) → Hub | None

设置当前事件循环对象。