Индекс высокоуровневого API

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

Задачи

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

run() Создаёт цикл событий, запуска корутин и закрытия цикла.
create_task() Запускает asyncio Задачу.
await sleep() Заснуть на заданное число секунд.
await gather() Планирование и ожидания какой-либо конкурентности.
await wait_for() Запуск с таймаутом.
await shield() Защита от отмены.
await wait() Мониторинг завершения.
current_task() Возвращение текущей Задачи.
all_tasks() Возвращает все задачи для цикла событий.
Task Объект Задачи.
run_coroutine_threadsafe() Запланировать корутину из другого потока ОС.
for in as_completed() Мониторинг завершения в цикле for.

Примеры

Очереди

Очереди следует использовать для распределения работы между несколькими асинхронными заданиями, реализовывая пулы соединений и 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().

Примеры