这逻辑不大对吧
难道不是数据到驿站, 多个快递员各行投递么
如果你每个协程都处理所有数据, 是有可能上个存储还没完成啊
【 在 sal0nbus 的大作中提到: 】
: 我遇到的问题是多个协程并行接收tick数据,然后在一个字典里更新生成k线的高开低收 ,但是多个协程同时修改更新字典,会出现一个协程更新字典的数据后,另外一个协程的上下文状态似乎并没有改变,字典的更新在这个协程中没有体现,比如新的一分钟tick数据来了后,就应该落盘上一分钟的k线,结果一个协程落盘k线后,另外一个协程由于数据字典的上下文没改变,这个协程收到新的tick也符合落盘的逻辑、也会落盘数据,从而造成重复记录多条k线数据
--
FROM 148.135.22.*