Python中如何实现带超时的队列

import queue
import threading

q = queue.Queue()

def producer():
    while True:
        q.put("pidancode.com")
        threading.Event().wait(1)

def consumer():
    while True:
        try:
            string = q.get(timeout=5) # 设置超时时间为5s
            print(string)
        except queue.Empty:
            print("Queue is empty.")
            break

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

producer_thread.start()
consumer_thread.start()

producer_thread.join()
consumer_thread.join()