@asyncio.coroutine
def queue_get():
    return (yield from asyncio.wait_for(q.get(), 0.051, loop=loop))
@asyncio.coroutine
def queue_get():
    return (yield from asyncio.wait_for(q.get(), 0.051, loop=loop))