Курс Python → Обмен данными с asyncio.Queue
Asyncio.Queue предоставляет удобный способ обмена данными между асинхронными задачами в Python. Он позволяет одной задаче помещать данные в очередь, а другой задаче забирать их для обработки. Это особенно полезно в случаях, когда необходимо организовать взаимодействие между разными частями программы, работающими параллельно.
Для использования asyncio.Queue необходимо создать объект класса asyncio.Queue(). Затем асинхронные задачи могут использовать методы put() для добавления элементов в очередь и get() для извлечения элементов из очереди. Кроме того, можно использовать методы task_done() для уведомления о завершении обработки элемента и join() для ожидания завершения обработки всех элементов очереди.
import asyncio
async def producer(queue):
for i in range(5):
await queue.put(i)
print(f'Producer put: {i}')
await queue.put(None)
async def consumer(queue):
while True:
data = await queue.get()
if data is None:
break
print(f'Consumer got: {data}')
queue.task_done()
async def main():
queue = asyncio.Queue()
producer_task = asyncio.create_task(producer(queue))
consumer_task = asyncio.create_task(consumer(queue))
await asyncio.gather(producer_task, consumer_task)
await queue.join()
asyncio.run(main())
В приведенном примере мы создаем две асинхронные задачи — producer, который помещает числа от 0 до 4 в очередь, и consumer, который извлекает и печатает эти числа. Когда producer завершает свою работу, он помещает значение None в очередь, чтобы consumer мог завершить свою работу. Мы используем asyncio.gather() для запуска обеих задач параллельно и await queue.join() для ожидания завершения обработки всех элементов очереди.
Другие уроки курса "Python"
- Преобразование символов в нижний регистр
- Основные методы NumPy
- Доступ к локальным переменным
- Работа с контекстными менеджерами
- Именование переменных в Python
- Копирование списков в Python
- Функция rsplit() в Python
- Преобразование строк в числа с плавающей запятой
- Глубокое копирование объектов
- Установка и использование Python-dateutil
- Генерация UUID в Python
- Передача аргументов в Python
- Преобразование регистра символов
- Атрибуты класса и экземпляра
- Любовь к Python
- Модуль inspect
- Работа с CSV файлами в Python
- Работа с итераторами через срезы
- Преобразование списков в словарь
- Отслеживание выполнения программы с библиотекой tqdm
- Работа с буфером обмена на Python
- Инициализация переменных
- Применение промокода в Много лосося
- Генератор данных в Keras
- Метод enumerate() в Python
- Оператор space-invader
- Создание спинбокса в tkinter
- Блок else в Python
- Роль object и type в Python
- Красивый вывод списка
- Конкатенация строковых литералов
- Извлечение статей с newspaper3k
- Аннотации типов в Python
- Определение объема памяти объекта
- Математические функции в Python
- Функции all и any в Python
- Структурирование именованных констант
- Concrete Paths в Python
- Вычисление фазы комплексного числа
- Оператор assert в Python
- Метод join() для объединения элементов строки
- Создание namedtuple списком полей
- Создание копии списка в Python
- Генерация тестовых данных с factory_boy
- Закрытие файла в Python
- Работа с GitHub в Telegram
- Python Метод sleep() времени
- Работа с пользовательским вводом















