asyncio_sample.py

import asyncio


@asyncio.coroutine
def queue_loader(packet_queue):
    for i in range(1, 10):
        yield from packet_queue.put('item%' % i)
        yield from asyncio.sleep(1)

@asyncio.coroutine
def packet_printer(packet_queue):
    while True:
        print('blocked')
        item = yield from packet_queue.get()
        print('Works: ', item)


event_loop = asyncio.get_event_loop()

packet_queue = asyncio.Queue()

tasks = [
    event_loop.create_task(queue_loader(packet_queue)),
    event_loop.create_task(packet_printer(packet_queue)),
]

asyncio.wait(tasks)

event_loop.run_forever()