如何在on_message mqtt paho中处理同时到来的多个消息

import paho.mqtt.client as mqtt
import queue
import threading

message_queue = queue.Queue()

def on_message(client, userdata, message):
    message_queue.put(message)

def process_messages():
    while True:
        message = message_queue.get()
        # 处理消息
        print(f"处理消息: {message.topic} {str(message.payload)}")
        message_queue.task_done()

client = mqtt.Client()
client.on_message = on_message
client.connect("mqtt.eclipse.org", 1883, 60)
client.subscribe("test/topic")

# 启动消息处理线程
threading.Thread(target=process_messages, daemon=True).start()

client.loop_forever()

import paho.mqtt.client as mqtt
import threading

lock = threading.Lock()

def on_message(client, userdata, message):
    with lock:
        # 处理消息
        print(f"处理消息: {message.topic} {str(message.payload)}")

client = mqtt.Client()
client.on_message = on_message
client.connect("mqtt.eclipse.org", 1883, 60)
client.subscribe("test/topic")

client.loop_forever()