在AIO异步I/O中,回调函数是用于在异步操作完成时被调用的函数。下面是一个包含代码示例的解决方法:
import asyncio
def callback_func(future):
print("异步操作已完成")
print("操作结果:", future.result())
async def main():
# 创建一个事件循环
loop = asyncio.get_running_loop()
# 创建一个Future对象
future = loop.create_future()
# 添加回调函数
future.add_done_callback(callback_func)
# 模拟异步操作
await asyncio.sleep(1)
future.set_result("操作成功")
# 运行主函数
asyncio.run(main())
在上面的示例中,我们定义了一个回调函数callback_func
,它将在异步操作完成时被调用。在main
函数中,我们创建了一个Future对象future
,并使用add_done_callback
方法将回调函数添加到Future对象上。然后,我们使用set_result
方法设置异步操作的结果,并在回调函数中打印操作结果。
要运行上述代码示例,您需要使用Python 3.7或更高版本,并安装相应的asyncio
模块。