Зачем нужны в asyncio get_running_loop() и set_event_loop()?

Question

[Иван Фурсов]

Извините за глупый вопрос, но я не смог найти понятного объяснения с примером

Answer 1

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

А что тут может быть непонятного? get_running_loop возвращает цикл событий, который потом можно использовать, а set_event_loop позволяет установить цикл событий в новом потоке, чтобы переиспользовать его.

Comments

[Иван Фурсов]

как это использовать

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

Дед Герасим, элементарно

loop = asyncio.get_event_loop()
...
asyncio.set_event_loop(loop)

[Иван Фурсов]

import asyncio

async def ge():
    print(1)
    await asyncio.sleep(1)
    print(2)

async def main():
    asyncio.create_task(ge())

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

asyncio.set_event_loop(loop)

loop.run_until_complete(main())
loop.run_forever()

вывел

1
1
2
2

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

Дед Герасим, всё правильно вывел.

[Иван Фурсов]

спс, но как использовать get_running_loop()?

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

Дед Герасим, так вы его и использовали в приведённом вами примере кода. Я никак не могу понять в чём у вас проблема.

[Иван Фурсов]

get_running_loop() я не использовал, я использовал get_event_loop()

а если заменить get_event_loop() на get_running_loop() то

Traceback (most recent call last):
  File "C:\Users\гыук\Desktop\змейка\eeeee.py", line 14, in <module>
    loop = asyncio.get_running_loop()
RuntimeError: no running event loop

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

Дед Герасим, в документации это описано

asyncio.get_running_loop()
If there is no running event loop a RuntimeError is raised.

asyncio.get_event_loop()
If there is no current event loop set in the current OS thread, the OS thread is main, and set_event_loop() has not yet been called, asyncio will create a new event loop and set it as the current one.

[Иван Фурсов]

Сергей Горностаев, не понимаю куда get_running_loop() вставить можно

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

Дед Герасим, get_running_loop нужно использовать тогда, когда нужна железная уверенность, что ваш код не будет запущен в многопоточном окружении. То есть почти всегда.

[Даниил Рыжов]

Дед Герасим, Допустим вы можете запускать новые потоки для синхронных функций(I/O Операции), которые не будут мешать остальным асинхронным

import asyncio
import concurrent.futures

_loop = asyncio.get_running_loop()
with concurrent.futures.ThreadPoolExecutor() as pool:
    positions_to_order, ids_to_order = await _loop.run_in_executor(pool, sync_func, *args)