如何解决Python多线程数据共享
我需要一些关于设计简单多线程程序的建议。我对线程有基本的了解,但我对在线程和对象范围之间共享数据感到困惑。
我的 t1
线程正在侦听 websocket 以获取消息,每次收到消息时,都会调用 process_message
函数。我想要在函数中发生的事情(而不是打印)是调用 portfolio.update_coin_pos(a,b)
。但是鉴于函数的定义位置,我无权访问 portfolio
对象。我有两个解决方案,但对我来说都不是很好:
- 我可以在
process_message
函数中定义main
,但这让我觉得非常难看。 - 将
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 举报,一经查实,本站将立刻删除。