asyncio producer consumer basic layout

asyncio_producer_consumer.py

import asyncio


async def producer(queue):
    i = 1
    while True:
        await queue.put(f'item {i}')
        i += 1
        await asyncio.sleep(5)


async def consumer(queue):
    while True:
        item = await queue.get()
        print(item)


if __name__ == '__main__':
    queue = asyncio.Queue()

    loop = asyncio.get_event_loop()
    loop.create_task(producer(queue))
    loop.create_task(consumer(queue))
    loop.run_forever()