确保可以由多个线程填充的python队列始终被清除，而不进行轮询。

import threading
import queue
import time

class ThreadSafeQueue:
    def __init__(self):
        self.queue = queue.Queue()
        self.stop_event = threading.Event()

    def put(self, item):
        self.queue.put(item)

    def get(self):
        return self.queue.get()

    def clear(self):
        with self.queue.mutex:
            self.queue.queue.clear()

    def stop(self):
        self.stop_event.set()

    def worker(self):
        while not self.stop_event.is_set():
            try:
                item = self.queue.get(timeout=1)  # 设置超时避免无限等待
                if item is None:  # 使用None作为停止信号
                    break
                # 处理item
                print(f"Processing {item}")
            except queue.Empty:
                continue

# 示例使用
if __name__ == "__main__":
    ts_queue = ThreadSafeQueue()

    # 启动工作线程
    worker_thread = threading.Thread(target=ts_queue.worker)
    worker_thread.start()

    # 填充队列
    for i in range(10):
        ts_queue.put(i)
        time.sleep(0.5)

    # 清除队列
    ts_queue.clear()

    # 停止工作线程
    ts_queue.stop()
    worker_thread.join()