how to add a coroutine to a running asyncio loop?

by

To add a function to an already running event loop you can use:

asyncio.ensure_future(my_coro())

In my case I was using multithreading (threading) alongside asyncio and wanted to add a task to the event loop that was already running. For anyone else in the same situation, be sure to explicitly state the event loop (as one doesn’t exist inside a Thread). i.e:

In global scope:

event_loop = asyncio.get_event_loop()

Then later, inside your Thread:

asyncio.ensure_future(my_coro(), loop=event_loop)

More Related Contents:

  1. How to limit concurrency with Python asyncio?
  2. Simplest async/await example possible in Python
  3. How can I wrap a synchronous function in an async coroutine?
  4. asyncio.sleep() vs time.sleep() in Python
  5. How to combine Celery with asyncio?
  6. How does asyncio actually work?
  7. Asynchronous method call in Python?
  8. How can I periodically execute a function with asyncio?
  9. Python 3.7 – asyncio.sleep() and time.sleep()
  10. FastAPI runs api-calls in serial instead of parallel fashion
  11. asyncio.sleep() vs time.sleep()
  12. multiprocessing vs multithreading vs asyncio in Python 3
  13. How to use asyncio with existing blocking library?
  14. Asyncio.gather vs asyncio.wait
  15. Sharing python objects across multiple workers
  16. Combine awaitables like Promise.all
  17. What kind of problems (if any) would there be combining asyncio with multiprocessing?
  18. How to test Python 3.4 asyncio code?
  19. Does asyncio supports asynchronous I/O for file operations?
  20. What does “SSLError: [SSL] PEM lib (_ssl.c:2532)” mean using the Python ssl library?
  21. How to call an async function without await?
  22. multiprocessing vs multithreading vs asyncio
  23. Use asyncio and Tkinter (or another GUI lib) together without freezing the GUI
  24. Using asyncio.Queue for producer-consumer flow
  25. asyncio.ensure_future vs. BaseEventLoop.create_task vs. simple coroutine?
  26. How to use await in a python lambda
  27. How to set class attribute with await in __init__
  28. How can I await inside future-like object’s __await__?
  29. Is there a way to use asyncio.Queue in multiple threads?
  30. “asyncio.run() cannot be called from a running event loop” when using Jupyter Notebook

Leave a Comment