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

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

Задачи¶

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

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

Примеры

Using asyncio.gather() to run things in parallel.
Using asyncio.wait_for() to enforce a timeout.
Cancellation.
Using asyncio.sleep().
Смотрите также главную страницу Tasks documentation page.

Очереди¶

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

`Queue`	Очередь в формате FIFO.
`PriorityQueue`	Приоритетная очередь.
`LifoQueue`	Очередь LIFO.

Примеры

Using asyncio.Queue to distribute workload between several Tasks.
Смотрите также Queues documentation page.

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

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

`await` `create_subprocess_exec()`	Создайте подпроцесс.
`await` `create_subprocess_shell()`	Запустите команду оболочки.

Примеры

Executing a shell command.
Смотрите также документацию subprocess APIs.

Потоки¶

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

`await` `open_connection()`	Установите TCP-соединение.
`await` `open_unix_connection()`	Установите соединение с сокетом Unix.
`await` `start_server()`	Запустите TCP-сервер.
`await` `start_unix_server()`	Запустите сервер сокетов Unix.
`StreamReader`	Высокоуровневый асинхронный/ожидающий объект для приема сетевых данных.
`StreamWriter`	Высокоуровневый асинхронный/ожидающий объект для отправки сетевых данных.

Примеры

Example TCP client.
Смотрите также документацию streams APIs.

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

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

`Lock`	Блокировка мьютекса.
`Event`	Объект события.
`Condition`	Объект условия.
`Semaphore`	Семафор.
`BoundedSemaphore`	Ограниченный семафор.
`Barrier`	Барьерный объект.

Примеры

Using asyncio.Event.
Using asyncio.Barrier.
Смотрите также документацию по asyncio synchronization primitives.

Исключения¶

`asyncio.CancelledError`	Вызывается при отмене задачи. Смотрите также `Task.cancel()`.
`asyncio.BrokenBarrierError`	Поднимается при разрушении барьера. Смотрите также `Barrier.wait()`.

Примеры

Handling CancelledError to run code on cancellation request.
Смотрите также полный список asyncio-specific exceptions.

Расширяющий

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

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

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

Задачи¶

Очереди¶

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

Потоки¶

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

Исключения¶

Python 3.11

Содержание

Дополнительно

Вы здесь: