3.Task对象

2022-08-21 22:01:08 阅读：207 来源： 互联网

标签：Task 协程对象 create task print asyncio

Task对象用于调度或并发协程对象在事件循环中可以添加多个任务创建task对象三种方式创建task对象可以让协程加入事件循环中等待被调度执行 3.7版本之后加入asyncio.create_task方式在之前的版本可以使用低层级的asyncio.ensure_future 不建议手动实例化Task对象

asyncio.create_task(协程对象)

loop.create_task(协程对象)

asyncio.ensure_future(协程对象)

task示例

import asyncio


async def func():
    print(1)
    await asyncio.sleep(2)
    return '1'

async def main():
    print('start')
    # 创建task对象，创建task对象的同时，会将对应任务添加到事件循环
    task1 = asyncio.create_task(func())
    task2 = asyncio.create_task(func())

    # 执行task1的时候 遇到IO会直接切换到task2执行
    res1 = await task1
    res2 = await task2
    print(res1, res2)
asyncio.run(main())

'''
事件循环执行main之后创建了两个task并且将两个task添加到事件循环
执行task1的时候遇到io切换到task2执行，达到一个并发的效果
'''

await asyncio.wait示例

async def main():
    print('start')

    # 创建一个任务列表
    task_list = [
        # 创建任务,name用户指定任务的名字，自定义可以不设置
        asyncio.create_task(func(),name='n1'),
        asyncio.create_task(func(),name='n2')
    ]

    # 使用asyncio.wait等待任务列表中的任务全部执行完成
    # timeout是等待的超时时间，单位S，可以不设置
    # done是接收任务的返回值是执行完的对象集合
    # pending是 接收超时没有执行完的对象对象
    done, pending = await asyncio.wait(task_list, timeout=10)
    
    # 可以循环返回的执行完的对象集合，通过result拿到返回值
    for d in done:
        print(d.result())


asyncio.run(main())

标签：Task,协程,对象,create,task,print,asyncio
来源： https://www.cnblogs.com/Mickey-7/p/16611142.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

3.Task对象