https://nullprogram.com/blog/2020/05/24/

async.py

import asyncio
import time


async def heartbeat():
    while True:
        start = time.time()
        await asyncio.sleep(1)
        delay = time.time() - start - 1
        print(f"heartbeat delay = {delay:.3f}s")


JOB_DURATION = 0.01  # 10ms


async def process():
    time.sleep(JOB_DURATION)  # simulate CPU time


JOB_COUNT = 200

WORKER_COUNT = 4  # max "active" jobs at a time


async def main_with_queue():
    asyncio.create_task(heartbeat())

    await asyncio.sleep(2.5)

    queue = asyncio.Queue(maxsize=1)

    async def worker():
        while True:
            coro = await queue.get()
            await coro  # consider using try/except
            queue.task_done()

    workers = [asyncio.create_task(worker()) for _ in range(WORKER_COUNT)]

    print("begin processing")
    for _ in range(JOB_COUNT):
        await queue.put(process())
    await queue.join()
    print("end processing")

    for w in workers:
        w.cancel()

    await asyncio.sleep(2)


# asyncio.run(heartbeat())

asyncio.run(main_with_queue())