Python多线程数据共享

问题描述

我需要一些关于设计简单多线程程序的建议。我对线程有基本的了解，但我对在线程和对象范围之间共享数据感到困惑。

我的 t1 线程正在侦听 websocket 以获取消息，每次收到消息时，都会调用 process_message 函数。我想要在函数中发生的事情（而不是打印）是调用 portfolio.update_coin_pos(a,b)。但是鉴于函数的定义位置，我无权访问 portfolio 对象。我有两个解决方案，但对我来说都不是很好：

1. 我可以在 process_message 函数中定义 main，但这让我觉得非常难看。
2. 将 process_message 函数作为方法附加到 Portfolio。但对我来说，这似乎是在混合不应该混合的东西。 Portfolio 跟踪我的位置，而不是解码传入的消息。

为了清楚起见，我省略了一些代码。

class Portfolio:
    # other stuff

    def update_coin_pos(self,symbol,qty):
        self.positions[symbol] = qty

def process_message(msg):
    a = msg['e']
    b = msg['E']

    print(a,b)

def main()
    client = Client()
    portfolio = Portfolio()

    bm = BinanceSocketManager(client)
    bm.start_user_socket(process_message)

    t1 = Thread(target=bm.start,daemon = True)
    t1.set_daemon(True)
    t1.start()

    while True:
        # do stuff like print things to screen
        sleep(10)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）