Индекс высокоуровневого 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 | 
Объект 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 подпроцессов.
 
Потоки¶
Высокоуровневое 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 объект для отправки сетевых данных. | 
Примеры
- Пример TCP клиента.
 - См. также документацию по API потоков.
 
Синхронизация¶
Потокоподобные примитивы синхронизации, используемые в задачах.
Lock | 
Мьютексная блокировка. | 
Event | 
Объект события. | 
Condition | 
Объект состояния. | 
Semaphore | 
Семафор. | 
BoundedSemaphore | 
Ограниченный семафор. | 
Примеры
- Использование asyncio.Event.
 - См. также документацию по asyncio примитивам синхронизации.
 
Исключения¶
asyncio.TimeoutError | 
Поднимается по таймауту функций подобных wait_for().
Имейте в виду asyncio.TimeoutError  не связанно
с встроенным исключением TimeoutError. | 
asyncio.CancelledError | 
Поднимается при отмене задачи. См. также Task.cancel(). | 
Примеры
- Обработка CancelledError для запуска кода по факту отмены.
 - См. также полный перечень asyncio-специфичных исключений.
 
