Python中关于CallbackBase()的使用方法

CallbackBase()是Python中的一个回调基类，用于创建回调函数的基础类。回调函数是一种在特定事件发生时被调用的函数，用于处理该事件。

使用CallbackBase()可以创建一个自定义的回调函数类，该类必须继承自CallbackBase()。

以下是CallbackBase()的一个使用示例：

import asyncio

class MyCallback(asyncio.CallbackBase):
    def __init__(self, loop):
        self.loop = loop

    def callback(self, future):
        print('Callback called')
        print(f'Result: {future.result()}')
        self.loop.stop()

async def worker():
    await asyncio.sleep(1)
    return 'Result'

async def main(loop):
    callback = MyCallback(loop)
    future = asyncio.ensure_future(worker())
    future.add_done_callback(callback.callback)

    await asyncio.sleep(2)  # wait for the callback to be called

loop = asyncio.get_event_loop()
asyncio.ensure_future(main(loop))
loop.run_forever()
loop.close()

在上面的例子中，首先定义了一个继承自CallbackBase()的回调函数类MyCallback。在该类的构造函数中传入一个事件循环对象loop。

回调函数callback()被定义为接收一个Future对象作为参数，在该回调函数中，我们可以对Future对象的结果进行处理。在这个例子中，回调函数打印出Future对象的结果并停止事件循环。

在main()函数中，创建了一个MyCallback实例callback，并将其注册到Future对象的回调函数列表中。然后使用asyncio.ensure_future()函数将worker()函数封装成一个Task对象，该Task对象会在事件循环中被调度执行。

最后，使用asyncio.get_event_loop()函数获取默认的事件循环对象，并使用loop.run_forever()启动事件循环。

运行以上代码，结果输出如下：

Callback called
Result: Result

可以看到，回调函数成功处理了Future对象的结果。

通过CallbackBase()，我们可以轻松地创建自定义的回调函数，并在特定事件发生时执行相应的操作。这对于处理异步任务的结果，或者在特定事件发生时触发其他操作非常有用。