### 同步 FIFO 的代码实现 同步 FIFO 是一种线程安全的数据结构，允许多个线程在同一时间内访问队列而不发生冲突。Python 中可以利用 `threading` 和 `queue` 模块来实现这一功能。 以下是基于 Python 的同步 FIFO 队列的代码实现： ```python import threading import queue # 创建一个最大容量为 10 的同步 FIFO 队列 fifo_queue = queue.Queue(maxsize=10) def producer(): """生产者线程""" for i in range(20): # 生产 20 个项目 try: fifo_queue.put(i, block=True, timeout=1) # 尝试放入项目到队列中 print(f"Produced: {i}") except queue.Full: print("Queue is full, cannot produce more.") def consumer(): """消费者线程""" while True: try: item = fifo_queue.get(block=True, timeout=2) # 尝试从队列获取项目 print(f"Consumed: {item}") fifo_queue.task_done() # 告知此任务已完成 except queue.Empty: print("Queue is empty, stopping consumption.") 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() print("All tasks completed.") ``` #### 解析 上述代码实现了多线程环境下的同步 FIFO 队列[^2]。 - **生产者**：通过 `put()` 方法向队列添加数据项。如果队列已满，则会阻塞直到有可用空间或将抛出异常。 - **消费者**：通过 `get()` 方法从队列取出数据项。如果队列为空，则会阻塞等待新数据到达或将抛出异常。 - 使用 `task_done()` 来标记某个任务已经完成，从而允许主线程调用 `join()` 等待所有任务结束。 这种设计确保了多个线程之间的协调工作，避免竞争条件的发生。 另外，在某些场景下也可以考虑使用单链表手动实现 FIFO 队列[^3]。虽然这种方式不涉及线程安全性问题，但在高并发环境下可能需要额外引入锁机制以保障一致性。