Future类

8.1 Future类的主要特点

Future类在asyncio模块中，代表一个未来可用的异步操作结果。 Future对象用于管理异步任务的状态和结果。

Future类的主要特点

Future对象是一个结果的容器，当任务完成时，结果就会变得可用。 它提供了一个接口，用于获取结果或异常，这些将在异步操作完成后设置。

创建和管理Future对象

• 创建：通常使用loop.create_future()创建。
• 设置结果：用set_result(result)方法设置结果。
• 设置异常：异常通过set_exception(exception)方法设置。

主要方法和属性

set_result(result):

为Future对象设置结果。所有等待该对象的协程将立即用此结果恢复。

set_exception(exception):

为Future对象设置异常。所有等待该对象的协程将立即以此异常恢复。

result():

返回Future对象的结果（如果可用）。如果操作以异常结束，抛出该异常。

exception():

返回异常（如果已设置），或None，如果Future对象尚未完成或成功完成。

done():

返回True，如果Future对象完成（有结果或异常）。

add_done_callback(callback):

添加一个将在Future对象完成时调用的回调。

8.2 使用示例

设置和获取结果

import asyncio

async def set_future_result(fut, delay):
    await asyncio.sleep(delay)
    fut.set_result("Future result is ready")
            
async def main():
    loop = asyncio.get_running_loop()
    fut = loop.create_future()
    asyncio.create_task(set_future_result(fut, 2))
    result = await fut
    print(result)
            
asyncio.run(main())

处理异常

import asyncio

async def set_future_exception(fut, delay):
    await asyncio.sleep(delay)
    fut.set_exception(ValueError("An error occurred"))
            
async def main():
    loop = asyncio.get_running_loop()
    fut = loop.create_future()
    asyncio.create_task(set_future_exception(fut, 2))
    try:
        result = await fut
    except ValueError as e:
        print(f"Caught an exception: {e}")

asyncio.run(main())

与任务的交互

通常Future对象与Tasks任务一起使用。当任务通过asyncio.create_task()创建时，自动创建一个Future对象，可以用于跟踪和管理任务状态。

import asyncio

async def example_coroutine():
    await asyncio.sleep(1)
    return "Task result"
            
async def main():
    task = asyncio.create_task(example_coroutine())
    print(await task)
            
asyncio.run(main())

8.3 优点和特点

Future对象允许管理异步操作的结果和异常，提供灵活性和对执行流程的控制。Future可以用于各种异步编程场景，包括任务、定时器、回调等等。

通常Future对象与Tasks任务一起使用。这个方法允许更高效地控制异步操作的执行和状态。

限制

在某些情况下，使用Future可能比使用更高级的抽象（例如Tasks或协程）要复杂。使用Future可能需要更多手动管理异步操作的状态和结果。