concurrency4.py

import asyncio
from typing import Any, List, Callable, Coroutine

async def async_io_worker(time_sec: int) -> str:
    await asyncio.sleep(time_sec)
    return f"Waited for {time_sec}s..."
    
async def async_scheduler(instances: int, worker: Coroutine, args: List[Any]) -> None:
    coroutines = [worker(*args) for _ in range(instances)]
    await asyncio.gather(*coroutines)
    
print("Coroutine Execution, I/O bound")
with timer():
    asyncio.run(async_scheduler(8, async_io_worker, [3]))