@asyncio.coroutine
def test():
    tasks = [asyncio.Task(worker(), loop=self.loop) for index in range(2)]
    (yield from q.join())
    return tasks
@asyncio.coroutine
def test():
    tasks = [asyncio.Task(worker(), loop=self.loop) for index in range(2)]
    (yield from q.join())
    return tasks