Python中如何实现线程安全的优先队列

import queue
import threading

class Task:
    def __init__(self, priority, description):
        self.priority = priority
        self.description = description

    def __lt__(self, other):
        return self.priority < other.priority

q = queue.PriorityQueue()

# 生产者线程
def producer():
    for i in range(10):
        t = Task(i, f"Task {i}")
        q.put(t)
        print(f"Task {i} added to queue")

# 消费者线程
def consumer():
    while not q.empty():
        t = q.get()
        print(f"Processing task {t.description}")

producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

producer_thread.start()
consumer_thread.start()

producer_thread.join()
consumer_thread.join()