Документация Python неофициальный перевод
Содержание страницы

Указатель API высокого уровняHigh-level API Index

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

ЗадачиTasks

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

run()

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

create_task()

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

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.

Примеры

ОчередиQueues

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

Queue

Очередь FIFO.

PriorityQueue

Очередь с приоритетом.

LifoQueue

Очередь LIFO.

Примеры

ПодпроцессыSubprocesses

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

await create_subprocess_exec()

Создание подпроцесса.

await create_subprocess_shell()

Выполнение команды оболочки.

Примеры

Потоки данныхStreams

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

await open_connection()

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

await open_unix_connection()

Установка соединения через Unix-сокет.

await start_server()

Запуск TCP-сервера.

await start_unix_server()

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

StreamReader

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

StreamWriter

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

Примеры

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

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

Lock

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

Event

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

Condition

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

Semaphore

Семафор.

BoundedSemaphore

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

Примеры

ИсключенияExceptions

asyncio.TimeoutError

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

asyncio.CancelledError

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

Примеры