Курс Python → Запуск асинхронной корутины

Для запуска асинхронной корутины из другого потока в Python можно использовать функцию asyncio.run_coroutine_threadsafe. Это удобный способ вызвать асинхронную функцию из кода, который работает в другом потоке. Давайте рассмотрим пример использования этой функции.

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


import asyncio

async def my_coroutine():
    # Некоторые асинхронные операции
    await asyncio.sleep(1)
    print("Асинхронная операция завершена")

Далее мы создаем новый цикл событий с помощью asyncio.new_event_loop() и устанавливаем его текущим с помощью asyncio.set_event_loop(loop). Это необходимо для того, чтобы корутина выполнилась в правильном контексте. Затем мы запускаем корутину с помощью asyncio.run_coroutine_threadsafe.


loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)

# Вызываем корутину из другого потока
asyncio.run_coroutine_threadsafe(my_coroutine(), loop)

Таким образом, мы успешно запустили асинхронную корутину my_coroutine из другого потока, используя функцию asyncio.run_coroutine_threadsafe. Это позволяет нам эффективно управлять асинхронными операциями в Python и избежать блокировок потоков.

Твои коллеги будут рады, поделись в