python3 使用 asyncio

发布时间:2019-10-17 09:07:42编辑:auto阅读(675)

    python3提供了协程专用的关键字async await, 还提供了asyncio库, 来进行异步非阻塞的io操作

    异步非阻塞的io操作?

    没有老师检查我也不知道自己算不算完全懂了, 就不做无用功尝试说得通俗易懂了.
    想要从原理开始理解的话, 推荐tornado的文档

    我为何使用asyncio来代替传统线程进行io操作?

    • 由于时间主要耗费在io操作上, 其他操作并发需求不大.
    • 不用规定并行多少, 比较方便稳定.
    • 熟悉tornado工作原理

    举例

    并行访问某网页十次

    import asyncio
    import requests
    loop = asyncio.get_event_loop()
    async def t():                                                    
        get = lambda:requests.get('http://baidu.com')
        temp = await loop.run_in_executor(None, get)
        print(temp)   
    loop.run_until_complete(asyncio.gather(*[t() for i in range(10)]))

    上面这几行代码就可以完成这些操作了.

    loop = asyncio.get_event_loop() 协程本身并不具备并行能力, 但是有了这个事件loop就可以进行并行io请求

    get = lambda:requests.get('http://baidu.com')
    temp = await loop.run_in_executor(None, get)

    一般函数是无法被await修饰的, 必须用api封装一下(感觉很像threading), 我之所以再封装一次get, 是因为run_in_executor传参数比较坑, 不支持**kwargs

    loop.run_until_complete(asyncio.gather(*[t() for i in range(10)]))

    run_until_complete这个api是指运行内容物直到结束(api如其名), gather是把任务组合到一起, 如果*的部分有迷惑的话, 你写asycio.gather(t(),t(), t()...)也是可以的.

    おわり.

关键字