Spec-Zone.ru › Python 3.11

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

Эта страница содержит список всех API asyncio, поддерживающих async/await.

Задачи

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

run()

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

Runner

Менеджер контекста, упрощающий вызовы нескольких асинхронных функций.

Task

Объект задачи.

TaskGroup

Менеджер контекста, содержащий группу задач. Обеспечивает удобный и надёжный способ ожидания завершения всех задач в группе.

create_task()

Запускает асинхронную задачу и возвращает её.

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.

Примеры

  • Использование asyncio.gather() для параллельного выполнения.
  • Использование asyncio.wait_for() для задания таймаута.
  • Отмена.
  • Использование asyncio.sleep().
  • См. также основную страницу документации по задачам.

Очереди

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

Queue

Очередь FIFO.

PriorityQueue

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

LifoQueue

Очередь LIFO.

Примеры

  • Использование asyncio.Queue для распределения нагрузки между несколькими задачами.
  • См. также страницу документации по очередям.

Подпроцессы

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

await create_subprocess_exec()

Создаёт подпроцесс.

await create_subprocess_shell()

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

Примеры

  • Выполнение команды оболочки.
  • См. также документацию по API подпроцессов.

Потоки

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 для отправки сетевых данных.

Примеры

  • Пример TCP-клиента.
  • См. также документацию по API потоков.

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

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

Lock

Мьютекс-блокировка.

Event

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

Condition

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

Semaphore

Семафор.

BoundedSemaphore

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

Barrier

Объект барьера.

Примеры

  • Использование asyncio.Event.
  • Использование asyncio.Barrier.
  • См. также документацию по асинхронным примитивам синхронизации.
END_OF_DOCUMENT_MARKER

Исключения

asyncio.CancelledError

Выбрасывается, когда задача Task отменена. См. также Task.cancel().

asyncio.BrokenBarrierError

Выбрасывается, когда барьер Barrier нарушен. См. также Barrier.wait().

Примеры

  • Обработка CancelledError для выполнения кода при запросе отмены.
  • См. также полный список исключений, специфичных для asyncio.

© 2001–2023 Python Software Foundation
Licensed under the PSF License.
https://docs.python.org/3.11/library/asyncio-api-index.html

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API