[Async worker] #python

woker.py

import asyncio


async def queue(task_name):
    i = 0
    while True:
        if i >= 5:
            return True
        print(f"checking queue for task {task_name}")
        i += 1
        await asyncio.sleep(0.1)


async def mlstask(task_name):
    while True:
        if await queue(task_name):
            await asyncio.sleep(0.5)
            print(f"finished process {task_name}")


async def create_tasks(num_tasks):
    loop = asyncio.get_running_loop()
    tasks = []
    for i in range(num_tasks):
        task = loop.create_task(mlstask(i))
        tasks.append(task)

def main():
    loop = asyncio.get_event_loop()
    loop.create_task(create_tasks(2))
    loop.run_forever()

if __name__ == '__main__':
    main()