@asyncio.coroutine
def consumer(queue):
    try:
        (yield from asyncio.wait_for(queue.get(), 0.1, loop=self.loop))
    except asyncio.TimeoutError:
        pass
@asyncio.coroutine
def consumer(queue):
    try:
        (yield from asyncio.wait_for(queue.get(), 0.1, loop=self.loop))
    except asyncio.TimeoutError:
        pass