output/kp_client_msg_manager.py
@@ -12,7 +12,7 @@ CLIENT_IDS = ["zjb", "hxh"] __temp_msg_queue = queue.Queue() __temp_msg_queue = queue.Queue(maxsize=1000) class MsgQueueManager: @@ -21,7 +21,7 @@ # 添加消息,2s内有效 def add_msg(self, client_id, msg): if client_id not in self.__queue_dict: self.__queue_dict[client_id] = queue.Queue() self.__queue_dict[client_id] = queue.Queue(maxsize=1000) self.__queue_dict[client_id].put_nowait((time.time() + 2, msg))
