exploring python asyncio

async-exploration.py

import asyncio
import functools


# [ Helpers ]
async def run_blocking(func, *args, **kwargs):
    partial = functools.partial(func, *args, **kwargs)

    loop = asyncio.get_event_loop()
    await loop.run_in_executor(None, partial)


def queue_async(func, *args, **kwargs):
    loop = asyncio.get_event_loop()
    loop.create_task(func(*args, **kwargs))


def run_async_tasks():
    loop = asyncio.get_event_loop()
    loop.run_until_complete(asyncio.wait(asyncio.Task.all_tasks(loop)))
    loop.close()


# [ Tasks ]
RUN = True


async def stop():
    await asyncio.sleep(5)
    global RUN
    RUN = False


async def async_main():
    while RUN:
        await hello_world()


# [ Async Actions ]
async def hello_world():
    await run_blocking(print, 'hello world')


# [ Main ]
queue_async(async_main)
queue_async(stop)
run_async_tasks()

should probably be simplified with a class that holds the main loop, instead of calling get_event_loop in all of the helpers.