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、实例
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
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步骤
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
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如何在协程调用内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://www.py.cn/jishu/jichu/29985.html
