Курс 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"

  1. Работа со словарями Python
  2. Логирование с Logzero
  3. Метод get() для словарей
  4. Сортировка с параметром key
  5. История Python
  6. Создание и обучение модели с Keras
  7. Генератор чисел Фибоначчи
  8. Методы classmethod и staticmethod
  9. Работа с базами данных SQLite
  10. Генераторы в Python
  11. Создание новых функций с помощью functools.partial
  12. Сортировка данных с лямбда-функциями
  13. Ноутбуки AMD Ryzen ™ 4000: мощность и эффективность
  14. Синтаксис переменных цикла в Python
  15. Работа с географическими данными.
  16. lru_cache оптимизация функций
  17. Метод gt в Python
  18. Многострочные комментарии в Python
  19. Работа с массивами в Numpy
  20. Область видимости переменных
  21. Работа с коллекциями Python
  22. Операции с кортежами
  23. Создание словарей в Python
  24. Работа с срезами в Numpy
  25. Модуль subprocess: запуск внешних команд
  26. Библиотека funcy: удобные утилиты
  27. Проверка условий в Python
  28. Генератор списка в Python
  29. Аннотации типов в Python
  30. Профилирование кода на Python
  31. Класс-оболочка для словарей
  32. Работа с enumerate()
  33. Компиляция регулярных выражений
  34. Основы работы со строками в Python
  35. Python enumerate() функции
  36. Копирование списков в Python
  37. Работа с NumPy
  38. Отладка регулярных выражений в Python
  39. Переопределение метода __eq__
  40. Методы split() и join() — Python строк.
  41. Вывод баннеров
  42. Форматирование строк в Python
  43. Оптимизация гиперпараметров с Scikit Optimize
  44. Объединение списков в строку
  45. Абстракции словарей и множеств в Python

Marketello читают маркетологи из крутых компаний