介绍

获取协程返回值的四种方式：

1、通过ensure_future获取，本质是future对象中的result方

2、使用loop自带的create_task， 获取返回值

3、使用callback, 一旦await地方的内容运行完，就会运行callback

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

源码

import asyncio
from functools import partial


async def talk(name):
    print(f"talk function run.")
    await asyncio.sleep(0.1)
    return f"{name} talk!"


async def sleep(name):
    print(f"sleep function run.")
    await asyncio.sleep(0.1)
    return f"{name} sleep!"


def callback(name):
    print(f"主动抛出接收：{name}")


if __name__ == "__main__":
    # 通过ensure_future获取，本质是future对象中的result方法
    # loop = asyncio.get_event_loop()
    # get_future1 = asyncio.ensure_future(talk("Dog"))
    # get_future2 = asyncio.ensure_future(sleep("Cat"))
    # loop.run_until_complete(get_future1)
    # loop.run_until_complete(get_future2)
    # print(get_future1.result())
    # print(get_future2.result())

    # 使用loop自带的create_task， 获取返回值
    # loop = asyncio.get_event_loop()
    # task1 = loop.create_task(talk("Dog"))
    # task2 = loop.create_task(sleep("Cat"))
    # loop.run_until_complete(task1)
    # loop.run_until_complete(task2)
    # print(task1.result())
    # print(task2.result())

    # 使用callback, 一旦await地方的内容运行完，就会运行callback
    # loop = asyncio.get_event_loop()
    # task1 = loop.create_task(talk("Dog"))
    # task2 = loop.create_task(sleep("Cat"))
    # task1.add_done_callback(callback)
    # task2.add_done_callback(callback)
    # loop.run_until_complete(task1)
    # loop.run_until_complete(task2)
    # print(task1.result())
    # print(task2.result())

    # 使用partial这个模块向callback函数中传入值
    loop = asyncio.get_event_loop()
    task1 = loop.create_task(talk("Dog"))
    task2 = loop.create_task(talk("Cat"))
    task1.add_done_callback(partial(callback))
    task2.add_done_callback(partial(callback))
    loop.run_until_complete(task1)
    loop.run_until_complete(task2)
    print(task1.result())
    print(task2.result())

依次执行结果

通过ensure_future获取，本质是future对象中的result方法

使用loop自带的create_task， 获取返回值

用callback, 一旦await地方的内容运行完，就会运行callback

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

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。

猜你喜欢

• Python凯撒密码算法有哪些特征，原理是什么

  这篇文章主要为大家介绍了Python密码学Caesar Cipher凯撒密码算法教程，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

• Pytorch计算准确率怎样实现，方法是什么

  这篇文章主要介绍了在pytorch中计算准确率,召回率和F1值的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

• Python中如何利用占位符添加数据，具体怎么实现

  在pymysql中支持对占位符的处理，开发者需要在SQL中使用“%”定义占位符，在使用excute()方法执行时对占位符的数据进行填充即可，本文给大家介绍python连接数据库后通过占位符添加数据的方法，需要的朋友参考下吧

• 用pyecharts怎样绘制3D地图的效果

  这篇文章主要介绍了Python可视化神器pyecharts之绘制地理图表，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下

• Python中怎么给图片进行重命名，且做排序操作

  当想将照片序列合成延时摄影视频时，可能会发现照片中缺少一张，或者照片序列是跨时间、并不连续的，如图1所示，但PR中只有连续的照片序列才能导入。