zoukankan      html  css  js  c++  java
  • python asyncio 获取协程返回值和使用callback

    1. 获取协程返回值,实质就是future中的task

    import asyncio
    import time
    async def get_html(url):
    print("start get url")
    await asyncio.sleep(2)
    return "bobby"

    def callback(url, future):
    print(url)
    print("send email to bobby")

    if __name__ == "__main__":
    start_time = time.time()
    loop = asyncio.get_event_loop()
    get_future = asyncio.ensure_future(get_html("http://www.imooc.com")) # 相当于开启一个future
    loop.run_until_complete(get_future) # 事件循环
    print(get_future.result()) # 获取结果

    2. 使用loop自带的create task, 获取返回值

    # 获取协程的返回值
    import asyncio
    import time
    from functools import partial
    async def get_html(url):
        print("start get url")
        await asyncio.sleep(2)
        return "bobby"
    
    def callback(url, future):
        print(url)
        print("send email to bobby")
    
    if __name__ == "__main__":
        start_time = time.time()
        loop = asyncio.get_event_loop()
        task = loop.create_task(get_html("http://www.imooc.com"))
        loop.run_until_complete(task)
        print(task.result())

    3. 使用callback,只要await地方的内容一运行完,就会运行callback

    # 获取协程的返回值
    import asyncio
    import time
    from functools import partial
    async def get_html(url):
        print("start get url")
        await asyncio.sleep(2)
        return "bobby"
    
    def callback(future): #这里默认传入一个future对象
        print("send email to bobby")
    
    if __name__ == "__main__":
        start_time = time.time()
        loop = asyncio.get_event_loop()
        task = loop.create_task(get_html("http://www.imooc.com"))
        task.add_done_callback(callback)
        loop.run_until_complete(task)
        print(task.result())

    使用partial这个模块向callback函数中传入值

    # 获取协程的返回值
    import asyncio
    import time
    from functools import partial
    async def get_html(url):
        print("start get url")
        await asyncio.sleep(2)
        return "bobby"
    
    def callback(future):
        print("send email to bobby")
    
    def callback1(url, future): # 传入值的时候,future必须在最后一个
        print(url)
        print("send email to bobby")
    if __name__ == "__main__":
        start_time = time.time()
        loop = asyncio.get_event_loop()
        task = loop.create_task(get_html("http://www.imooc.com"))
        task.add_done_callback(partial(callback1, "http://www.imooc.com"))
        loop.run_until_complete(task)
        print(task.result())
  • 相关阅读:
    从C,C++,JAVA和C#看String库的发展(一)----C语言和C++篇
    Intent----android中的伟大邮差
    一步一步掌握线程机制(五)---等待与通知机制
    一步一步掌握线程机制(四)---同步方法和同步块
    一步一步掌握线程机制(三)---synchronized和volatile的使用
    利用单例模式解决全局访问问题
    一步一步掌握java的线程机制(二)----Thread的生命周期
    一步一步掌握java的线程机制(一)----创建线程
    如何快速学会android的四大基础----Service篇
    前端工程师必备实用网站
  • 原文地址:https://www.cnblogs.com/callyblog/p/11216961.html
Copyright © 2011-2022 走看看