如何同步多个socket.io客户端访问python中的单个双端队列/集合/列表？

Question

我同时订阅多个 socket.io 服务器，检查所有传入条目是否已被另一个 websocket 客户端处理/接收。服务器向我提供应添加到单个列表中的数据，列表的顺序很重要，因为它代表来自交易所的订单簿。一个条目不应添加两次。 使用我当前的解决方案，我遇到了竞争条件，据我所知，socket.io 正在使用 asyncio，简单的 threading.Lock 将无济于事。

sio = socketio.Client()
sio1 = socketio.Client()
locker = threading.Lock()
added_Orders = collections.deque(maxlen=40)

@sio.on('connect')
def connect():
    print('connection established')

@sio1.on('connect')
def connect():
    print('connection1 established')

@sio.on('add_order', namespace="/market")
def add_order(data):
    with locker:
        if data in added_Orders:
            return
        else:
            added_Orders.append(data)
    webRecv.process_add(data)

@sio1.on('add_order', namespace="/market")
def add_order1(data):
    with locker:
        if data in added_Orders:
            return
        else:
            added_Orders.append(data)
    webRecv.process_add(data)