Высокоуровневый индекс API

На этой странице перечислены все высокоуровневые API async/await с поддержкой asyncio.

Задачи

Утилиты для запуска программ asyncio, создания Задач и ожидания нескольких действий с таймаутами.

run()

Создайте цикл событий, запустите coroutine, закройте цикл.

create_task()

Запустите задачу asyncio Task.

await sleep()

Поспите в течение нескольких секунд.

await gather()

Планируйте и ожидайте одновременно.

await wait_for()

Запуск с тайм-аутом.

await shield()

Щит от отмены.

await wait()

Следите за выполнением.

current_task()

Возвращает текущую задачу.

all_tasks()

Возвращает все задачи для цикла событий.

Task

Объект задачи.

to_thread()

Асинхронный запуск функции в отдельном потоке ОС.

run_coroutine_threadsafe()

Запланировать корутину из другого потока ОС.

for in as_completed()

Контролируйте завершение работы с помощью цикла for.

Примеры

Очереди

Очереди следует использовать для распределения работы между несколькими Задачами asyncio, реализации пулов соединений и шаблонов pub/sub.

Queue

Очередь FIFO.

PriorityQueue

Очередь приоритетов.

LifoQueue

Очередь LIFO.

Примеры

Подпроцессы

Утилиты для порождения подпроцессов и запуска команд командного интерпретатора.

await create_subprocess_exec()

Создайте подпроцесс.

await create_subprocess_shell()

Запустите команду оболочки.

Примеры

Потоки

Высокоуровневые API для работы с сетевыми IO.

await open_connection()

Установите TCP-соединение.

await open_unix_connection()

Установите соединение с сокетом Unix.

await start_server()

Запустите сервер TCP.

await start_unix_server()

Запустите сервер сокетов Unix.

StreamReader

Высокоуровневый объект async/await для получения сетевых данных.

StreamWriter

Высокоуровневый объект async/await для отправки сетевых данных.

Примеры

Синхронизация

Примитивы синхронизации, похожие на потоки, которые можно использовать в задачах.

Lock

Блокировка мьютекса.

Event

Объект события.

Condition

Объект условия.

Semaphore

Семафор.

BoundedSemaphore

Ограниченный семафор.

Примеры

Исключения

asyncio.TimeoutError

Вызывается по таймауту функциями типа wait_for(). Следует помнить, что asyncio.TimeoutError является не связанным со встроенным исключением TimeoutError.

asyncio.CancelledError

Возникает при отмене задачи. См. также Task.cancel().

Примеры

Вернуться на верх