Индекс высокоуровневого 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-специфичных исключений.