python Task在协程调用实例讲解

1、说明

Tasks用于并发调度协程,通过asyncio.create_task(协程对象)创建Task对象,使协程能够加入事件循环,等待调度执行。除使用asyncio.create_task()函数外,还可使用低级loop.create_task()或ensure_future()函数。推荐使用手动实例Task对象。

2、使用注意

python3.7中添加到asyncio.create_task函数。在python3.7之前,可以使用低级asyncio.ensure_future函数。

3、实例

import asyncio  async def func():    print(1)    await asyncio.sleep(2)    print(2)    return "返回值"  async def main():    print("main开始")    # 创建协程,将协程封装到一个Task对象中并立即添加到事件循环的任务列表中,等待事件循环去执行(默认是就绪状态)。    task1 = asyncio.create_task(func())    # 创建协程,将协程封装到一个Task对象中并立即添加到事件循环的任务列表中,等待事件循环去执行(默认是就绪状态)。    task2 = asyncio.create_task(func())    print("main结束")    # 当执行某协程遇到IO操作时,会自动化切换执行其他任务。    # 此处的await是等待相对应的协程全都执行完毕并获取结果    ret1 = await task1    ret2 = await task2    print(ret1, ret2)        asyncio.run(main())

知识点扩展:

python asyncio 协程调用task步骤

import asyncioasync def compute(x, y):    print("Compute %s + %s ..." % (x, y))    await asyncio.sleep(1.0)    return x + yasync def print_sum(x, y):    result = await compute(x, y)    print("%s + %s = %s" % (x, y, result))loop = asyncio.get_event_loop()loop.run_until_complete(print_sum(1, 2))loop.close()

到此这篇关于python Task在协程调用实例讲解的文章就介绍到这了,更多相关python Task如何在协程调用内容请搜索 以前的文章或继续浏览下面的相关文章希望大家以后多多支持 !

相关文章

发表新评论