线程安全队列实现: pop()的高效实现

import threading

class ThreadSafeQueue:
    def __init__(self):
        self.queue = []
        self.mutex = threading.Lock()
        self.condition = threading.Condition(lock=self.mutex)

    def pop(self):
        with self.condition:
            while len(self.queue) == 0:
                self.condition.wait()
            return self.queue.pop(0)

    def push(self, item):
        with self.condition:
            self.queue.append(item)
            self.condition.notify()

# 示例用法
queue = ThreadSafeQueue()

# 线程1执行pop()操作
def thread1_func():
    item = queue.pop()
    print("Thread 1 popped item:", item)

# 线程2执行push()操作
def thread2_func():
    queue.push("Hello, World!")

thread1 = threading.Thread(target=thread1_func)
thread2 = threading.Thread(target=thread2_func)

thread1.start()
thread2.start()

thread1.join()
thread2.join()