在asyncio.Protocol.data_received()中调用协程并获得未来？

import asyncio

class MyProtocol(asyncio.Protocol):
    def data_received(self, data):
        # 调用协程并获得未来
        future = asyncio.ensure_future(self.process_data(data))
        future.add_done_callback(self.handle_result)

    async def process_data(self, data):
        # 协程的具体逻辑
        await asyncio.sleep(1)  # 模拟耗时操作
        return data.upper()

    def handle_result(self, future):
        # 处理协程的执行结果
        result = future.result()
        print("Processed data:", result)

# 创建事件循环并运行协程
loop = asyncio.get_event_loop()
coro = loop.create_server(MyProtocol, '127.0.0.1', 8888)
server = loop.run_until_complete(coro)

# 运行事件循环
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass

# 关闭服务器和事件循环
server.close()
loop.run_until_complete(server.wait_closed())
loop.close()