asyncio异步编程(8)

当前位置:

首页 > temp > 简明python教程 >

asyncio异步编程(8)

注意：asyncio.wait 源码内部会对列表中的每个协程执行ensure_future从而封装为Task对象，所以在和wait配合使用时task_list的值为[func(),func()] 也是可以的。

示例3：

				
										import asyncio

										async def func():

										    print("执行协程函数内部代码")

										    # 遇到IO操作挂起当前协程（任务），等IO操作完成之后再继续往下执行。当前协程挂起时，事件循环可以去执行其他协程（任务）。

										    response = await asyncio.sleep(2)

										    print("IO请求结束，结果为：", response)

										coroutine_list = [func(), func()]

										# 错误：coroutine_list = [ asyncio.create_task(func()), asyncio.create_task(func()) ] 

										# 此处不能直接 asyncio.create_task，因为将Task立即加入到事件循环的任务列表，

										# 但此时事件循环还未创建，所以会报错。

										# 使用asyncio.wait将列表封装为一个协程，并调用asyncio.run实现执行两个协程

										# asyncio.wait内部会对列表中的每个协程执行ensure_future，封装为Task对象。

										done,pending = asyncio.run( asyncio.wait(coroutine_list) )

3.2.4 asyncio.Future对象

A Futureis a special low-level awaitable object that represents an eventual result of an asynchronous operation.

asyncio中的Future对象是一个相对更偏向底层的可对象，通常我们不会直接用到这个对象，而是直接使用Task对象来完成任务的并和状态的追踪。（ Task 是 Futrue的子类）

Future为我们提供了异步编程中的最终结果的处理（Task类也具备状态处理的功能）。

示例1：

				
										async def main():

										    # 获取当前事件循环

										    loop = asyncio.get_running_loop()

										    # # 创建一个任务（Future对象），这个任务什么都不干。

										    fut = loop.create_future()

										    # 等待任务最终结果（Future对象），没有结果则会一直等下去。

										    await fut

										asyncio.run(main())

示例2：

				
										import asyncio

										async def set_after(fut):

										    await asyncio.sleep(2)

										    fut.set_result("666")

										async def main():

										    # 获取当前事件循环

										    loop = asyncio.get_running_loop()

										    # 创建一个任务（Future对象），没绑定任何行为，则这个任务永远不知道什么时候结束。

										    fut = loop.create_future()

										    # 创建一个任务（Task对象），绑定了set_after函数，函数内部在2s之后，会给fut赋值。

										    # 即手动设置future任务的最终结果，那么fut就可以结束了。

										    await loop.create_task(set_after(fut))

										    # 等待 Future对象获取 最终结果，否则一直等下去

										    data = await fut

										    print(data)

										asyncio.run(main())

栏目列表