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)