Python并发之异步I/O(async,await)-3

look_w

例子1

少废话,直接看例子。

    import asyncio
    import time
     
    start = time.time()
     
     
    def tic():
        return 'at %1.1f seconds' % (time.time() - start)
     
     
    async def gr1():
        # Busy waits for a second, but we don't want to stick around...
        print('gr1 started work: {}'.format(tic()))
        # 暂停两秒，但不阻塞时间循环，下同
        await asyncio.sleep(2)
        print('gr1 ended work: {}'.format(tic()))
     
     
    async def gr2():
        # Busy waits for a second, but we don't want to stick around...
        print('gr2 started work: {}'.format(tic()))
        await asyncio.sleep(2)
        print('gr2 Ended work: {}'.format(tic()))
     
     
    async def gr3():
        print("Let's do some stuff while the coroutines are blocked, {}".format(tic()))
        await asyncio.sleep(1)
        print("Done!")
     
    # 事件循环
    ioloop = asyncio.get_event_loop()
     
    # tasks中也可以使用asyncio.ensure_future(gr1())..
    tasks = [
        ioloop.create_task(gr1()),
        ioloop.create_task(gr2()),
        ioloop.create_task(gr3())
    ]
    ioloop.run_until_complete(asyncio.wait(tasks))
    ioloop.close()
     
     
    output：
        gr1 started work: at 0.0 seconds
        gr2 started work: at 0.0 seconds
        Let's do some stuff while the coroutines are blocked, at 0.0 seconds
        Done!
        gr2 Ended work: at 2.0 seconds
        gr1 ended work: at 2.0 seconds

    asyncio.wait(...) 协程的参数是一个由future或协程构成的可迭代对象；wait 会分别
    把各个协程包装进一个 Task 对象。最终的结果是，wait 处理的所有对象都通过某种方式变成 Future 类的实例。wait 是协程函数，因此返回的是一个协程或生成器对象。

    ioloop.run_until_complete 方法的参数是一个future或协程。如果是协程，run_until_complete方法与 wait 函数一样，把协程包装进一个 Task 对象中。

    在 asyncio 包中，future和协程关系紧密，因为可以使用 yield from 从asyncio.Future 对象中产出结果。这意味着，如果 foo 是协程函数（调用后返回协程对象），抑或是返回Future 或 Task 实例的普通函数，那么可以这样写：res = yield from foo()。这是 asyncio 包的 API 中很多地方可以互换协程与期物的原因之一。 例如上面的例子中tasks可以改写成协程列表：tasks = [gr1(), gr(2), gr(3)]