How can I wrap a synchronous function in an async coroutine?

by

Eventually I found an answer in this thread. The method I was looking for is run_in_executor. This allows a synchronous function to be run asynchronously without blocking an event loop.

In the sleep example I posted above, it might look like this:

import asyncio
from time import sleep

async def sleep_async(loop, delay):
    # None uses the default executor (ThreadPoolExecutor)
    await loop.run_in_executor(None, sleep, delay)
    return 'I slept asynchronously'

Also see the following answer -> How do we call a normal function where a coroutine is expected?

More Related Contents:

  1. How to limit concurrency with Python asyncio?
  2. Simplest async/await example possible in Python
  3. asyncio.sleep() vs time.sleep() in Python
  4. How to call an async function without await?
  5. how to add a coroutine to a running asyncio loop?
  6. How to combine Celery with asyncio?
  7. How does asyncio actually work?
  8. Asynchronous method call in Python?
  9. How can I periodically execute a function with asyncio?
  10. Python 3.7 – asyncio.sleep() and time.sleep()
  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. Learning asyncio: “coroutine was never awaited” warning error
  18. What kind of problems (if any) would there be combining asyncio with multiprocessing?
  19. How to test Python 3.4 asyncio code?
  20. Does asyncio supports asynchronous I/O for file operations?
  21. What does “SSLError: [SSL] PEM lib (_ssl.c:2532)” mean using the Python ssl library?
  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 set class attribute with await in __init__
  27. aiohttp: set maximum number of requests per second
  28. How can I await inside future-like object’s __await__?
  29. Is there a way to use asyncio.Queue in multiple threads?
  30. aiohttp: rate limiting parallel requests

Leave a Comment