Как в новом потоке запустить асинхронную функцию?

Question

[Totem]

Есть асинхронная функция, в которой нужно вызвать другую асинхронную функцию в новом потоке. Каким методом это сделать?

from threading import Thread

async def aaa(): # Функция которую нужно запустить в новом потоке
    pass

async def ddd(): # Функция из которой нужно запустить новый поток
    Thread(target=aaa).start()

Но я обламываюсь, так как там возникает Runtime ошибка. Может есть предложения?

Comments

[Дмитрий Шицков]

в новом потоке

а зачем - точно надо?

[Totem]

Дмитрий Шицков, надо точно.

[Дмитрий Шицков]

InternetMaster, а может нет?
Можешь все-таки не скрывать цель использование нового потока в асинхронном коде? Вариантов решения может быть более одного.

[Totem]

Дмитрий Шицков, в чем проблема хотя бы сказать хотя бы одно решение?

[Totem]

Dr. Bacon, например нужно выполнять 2 работы параллельно, но каждую с разным интервалом по времени. Обычный asyncio.sleep() останавливает на один промежуток сразу обе функции. Или например чтобы сделать системные вызовы неблокирующими.

[Totem]

Dr. Bacon, все понял

Answer 1

[Дмитрий Шицков]

Вот все решения которые пришли в голову от простого и правильного к нетипичному.

1. Не использовать новые потоки, потому что код и так асинхронный
   
2. Сделать функцию aaa синхронной - проблема с запуском нового потока уйдет
   
3. Если aaa невозможно изменить - нужно сделать обертку в виде синхронной функции (или декоратора), в который создать новый eventloop (предположим используется asyncio)
   

def wrapper(*args, **kwargs):
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    loop.run_until_complete(aaa(*args, **kwargs))
    loop.close()

Comments

[Сергей Горностаев]

Но последнее надо делать только тогда, когда точно понимаешь, что делаешь. Если заводить цикл событий на каждый поток, то работать будет ооочень медленно.

Answer 2

[Сергей Горностаев]

Есть не предположение, а уверенность, что смешивать многопоточность с асинхронностью - плохая идея и не нужно почти никогда.

Comments

[AlbertForest]

У меня есть асинхронная функция, которая работает в отдельном потоке. В основном потоке работает django.
Поток с асинхронной функцией запускается при старте сервера и не прекращается до его остановки. Он получает данные из redis, которые туда кладет основной поток. (некоторое подобие тасков celery, но celery тоже не особо дружит с asyncio, поэтому реализовал так, дабы не плодить кучу воркеров и не отказываться от прелестей asyncio). Он так же использует модули django, по этому не вынесен за пределы web приложения. Если такой подход является плохим, как бы вы реализовали такую задачу?

[Сергей Горностаев]

i3a4em, зависит от того, что этот код делает.

[AlbertForest]

Сергей Горностаев, Я опубликовал свой вопрос с подробностями https://qna.habr.com/q/1132734. Буду рад мнению знатока)

Answer 3

[freeam]

Так делать НЕПРАВИИЛЬНО! Сам интепретатор Вам об этом говорит. Это несовместимые вещи.