@asyncio.coroutine
def queue_get():
    loop.call_later(0.01, q.get_nowait)
    queue_put_task = asyncio.Task(queue_put(), loop=loop)
    (yield from started.wait())
    self.assertFalse(finished)
    (yield from queue_put_task)
    self.assertTrue(finished)
@asyncio.coroutine
def queue_get():
    loop.call_later(0.01, q.get_nowait)
    queue_put_task = asyncio.Task(queue_put(), loop=loop)
    (yield from started.wait())
    self.assertFalse(finished)
    (yield from queue_put_task)
    self.assertTrue(finished)