如何在父类中初始化子类并实现子类的异步自更新？

完全可以实现，但你给出的示例代码存在几个关键问题，需要调整才能正常运行：

核心问题修正点 #

• 异步函数未正确启动：DataService.__init__中直接调用异步方法update()不会触发异步执行，必须通过异步事件循环来调度这个任务。
• 同步循环阻塞异步任务：Analyze.analyze_data里的同步死循环会占用主线程，导致WebSocket的异步更新任务无法得到执行机会，需要将分析逻辑也适配异步环境，或者用线程分离两个任务。
• 类定义缺失：示例中的Child类未定义，结合你的需求，这里应该是初始化DataService子类实例。

修正后的代码示例 #

import asyncio
import pandas as pd

class Analyze:
    def __init__(self):
        self.data_service = DataService()
        # 启动异步更新任务
        asyncio.create_task(self.data_service.update())

    async def analyze_data(self):
        while True:
            # 这里添加数据分析逻辑，比如打印当前数据行数
            if not self.data_service.data.empty:
                print(f"当前数据行数: {len(self.data_service.data)}")
            # 控制分析频率，避免过度占用资源
            await asyncio.sleep(1)

class DataService:
    def __init__(self):
        self.data = pd.DataFrame()

    async def update(self):
        # 模拟WebSocket异步更新数据的逻辑
        while True:
            # 示例：每秒添加一行测试数据
            new_row = pd.DataFrame({"value": [asyncio.get_event_loop().time()]})
            self.data = pd.concat([self.data, new_row], ignore_index=True)
            await asyncio.sleep(1)

# 启动异步事件循环
async def main():
    anlz = Analyze()
    await anlz.analyze_data()

asyncio.run(main())

方案说明 #

• 两个类保持独立职责：DataService专注于WebSocket数据更新，Analyze专注于数据分析，符合你不希望整合的需求。
• 通过asyncio.create_task启动DataService的异步更新任务，避免阻塞主线程。
• 将analyze_data改为异步方法，使用await asyncio.sleep()让出线程，确保异步更新任务能正常执行。

内容的提问来源于stack exchange，提问作者Iman Fakhari