我有一个循环守护线程从web套接字接收数据,用值更新dict()。守护进程必须不断地运行更新,以保持数据的实时性。但是,我的其他线程(从1-15个其他线程或进程)只需要定期更新。如何从守护进程线程获取dict(),并定期将dict()分发给许多其他线程或进程?我错过了什么简单的方法吗?提前谢谢。我使用锁不可靠地提供一个线程的示例代码:import threading as t
from datetime import datetime<
我正在从websocket服务器接收有关一些金融市场状态的更新。但是,由于服务器的限制,我必须定期创建一个新的ws连接。来自新建立的连接的第一个消息是初始状态,随后的消息是小的“增量”消息,它只是让你知道如何更新状态。我没有包含实现细节,但我在建立新连接时会重新初始化我的内部状态对象。我有以下协程来处理传入的websocket消息,并定期关闭并建立新的ws连接: async with session.ws_connect('wss://