How can I periodically execute a function with asyncio?

by

For Python versions below 3.5:

import asyncio

@asyncio.coroutine
def periodic():
    while True:
        print('periodic')
        yield from asyncio.sleep(1)

def stop():
    task.cancel()

loop = asyncio.get_event_loop()
loop.call_later(5, stop)
task = loop.create_task(periodic())

try:
    loop.run_until_complete(task)
except asyncio.CancelledError:
    pass

For Python 3.5 and above:

import asyncio

async def periodic():
    while True:
        print('periodic')
        await asyncio.sleep(1)

def stop():
    task.cancel()

loop = asyncio.get_event_loop()
loop.call_later(5, stop)
task = loop.create_task(periodic())

try:
    loop.run_until_complete(task)
except asyncio.CancelledError:
    pass

More Related Contents:

  1. How to use asyncio with existing blocking library?
  2. Does asyncio supports asynchronous I/O for file operations?
  3. asyncio.ensure_future vs. BaseEventLoop.create_task vs. simple coroutine?
  4. When to use and when not to use Python 3.5 `await` ?
  5. How does asyncio actually work?
  6. “Fire and forget” python async/await
  7. What are type hints in Python 3.5?
  8. What is the ‘@=’ symbol for in Python?
  9. How to limit concurrency with Python 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. ImportError: No module named ‘django.core.urlresolvers’
  14. Simplest async/await example possible in Python
  15. “Asyncio Event Loop is Closed” when getting loop
  16. Self-reference or forward-reference of type annotations in Python [duplicate]
  17. Combine awaitables like Promise.all
  18. How to test Python 3.4 asyncio code?
  19. How to use ‘yield’ inside async function?
  20. How to call an async function without await?
  21. multiprocessing vs multithreading vs asyncio
  22. Why am I getting “invalid syntax” from an f-string? [duplicate]
  23. Using asyncio.Queue for producer-consumer flow
  24. How to set Python3.5.2 as default Python version on CentOS?
  25. How to set class attribute with await in __init__
  26. How can I await inside future-like object’s __await__?
  27. Is there a way to use asyncio.Queue in multiple threads?
  28. “asyncio.run() cannot be called from a running event loop” when using Jupyter Notebook
  29. how to add a coroutine to a running asyncio loop?
  30. How to combine Celery with asyncio?

Leave a Comment