asyncio for block function

asyncio_test.py

import asyncio
import time
import random


def random_sleep(task_id: int):
    for t in range(5):
        sleep = random.randrange(1000, 2000, 1)
        time.sleep(sleep / 1000)
        print(f'task_id: {task_id}, running ({t})')


async def main():
    loop = asyncio.get_event_loop()
    tasks = []
    for i in range(10):
        tasks.append(loop.run_in_executor(None, random_sleep, int(i)))

    for i in range(20):
        print(f'Running.... ({i})')
        time.sleep(0.5)
    await asyncio.gather(*tasks)

if __name__ == "__main__":
    asyncio.run(main())