Расширение

Написание пользовательского цикла событий

asyncio.AbstractEventLoop объявляет очень много методов. Реализация всех их с нуля — трудоёмкая задача.

Цикл может получить реализацию многих общих методов бесплатно, унаследовав от asyncio.BaseEventLoop.

В свою очередь, преемник должен реализовать ряд внутренних методов, объявленных, но не реализованных в asyncio.BaseEventLoop.

Например, loop.create_connection() проверяет аргументы, разрешает адреса DNS и вызывает loop._make_socket_transport(), который должен быть реализован унаследованным классом. Метод _make_socket_transport() не документирован и считается внутренним API.

Закрытые конструкторы Future и Task

asyncio.Future и asyncio.Task никогда не должны создаваться напрямую, используйте соответствующие фабрики loop.create_future() и loop.create_task(), или asyncio.create_task() вместо этого.

Однако, сторонние циклы событий могут использовать встроенные реализации future и task для получения сложного и высокооптимизированного кода бесплатно.

Для этой цели перечислены следующие внутренние конструкторы:

Future.__init__(*, loop=None)

Создать экземпляр встроенного будущего.

loop — необязательный экземпляр цикла событий.

Task.__init__(coro, *, loop=None, name=None, context=None)

Создать экземпляр встроенной задачи.

loop — необязательный экземпляр цикла событий. Остальные аргументы описаны в loop.create_task().

Изменено в версии 3.11: Добавлен аргумент context.

Поддержка жизненного цикла задачи

Реализация задачи третьей стороны должна вызывать следующие функции, чтобы задача оставалась видимой для asyncio.all_tasks() и asyncio.current_task():

asyncio._register_task(task)

Зарегистрировать новую задачу как управляемую asyncio.

Вызов функции из конструктора задачи.

asyncio._unregister_task(task)

Удалить задачу из внутренних структур asyncio.

Функция должна вызываться, когда задача близка к завершению.

asyncio._enter_task(loop, task)

Переключить текущую задачу на аргумент task.

Вызовите функцию непосредственно перед выполнением части встроенного корутина (coroutine.send() или coroutine.throw()).

asyncio._leave_task(loop, task)

Переключить текущую задачу обратно с task на None.

Вызовите функцию сразу после выполнения coroutine.send() или coroutine.throw().