async_producer_consumer.py

import asyncio
import random
import time


async def producer(queue):
    while True:
        await asyncio.sleep(2)
        await queue.put(random.randint(1, 100))


async def consumer(queue):
    while True:
        val = await queue.get()
        await asyncio.sleep(2)
        print(f"time: {time.strftime('%X')}, consumed: {val}")


async def main():
    queue = asyncio.Queue()
    await asyncio.gather(producer(queue), consumer(queue))


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