@asyncio.coroutine
def test():
    get_task = asyncio.Task(queue_get(), loop=loop)
    (yield from asyncio.sleep(0.01, loop=loop))
    q.put_nowait(1)
    return (yield from get_task)
@asyncio.coroutine
def test():
    get_task = asyncio.Task(queue_get(), loop=loop)
    (yield from asyncio.sleep(0.01, loop=loop))
    q.put_nowait(1)
    return (yield from get_task)