consumer_producer

async def producer(queue: Queue):
    for i in range(10):
        await asyncio.sleep(5)
        await queue.put(i)
    await queue.put(None)

async def consumer(queue: Queue):
    while True:
        value = await queue.get()
        if not value:
            break
        print(f'Get value: {value}')

async def run():
    queue = Queue()
    loop = asyncio.get_event_loop()
    loop.create_task(fill_queue(queue))
    await consule_queue(queue)