### Python 实现生产者消费者问题的同步与互斥 Python 中可以使用多种方式实现生产者消费者问题中的同步与互斥，其中最常用的是基于 `threading` 模块中的条件变量 (`Condition`) 或者队列 (`Queue`) 来完成。以下是两种常见的实现方法。 --- #### 方法一：使用 `threading.Condition` 通过 `Condition` 对象，可以在多线程环境中实现复杂的同步逻辑。以下是一个完整的例子： ```python import threading import random import time class ProducerConsumerProblem: def __init__(self, size=5): self.buffer = [] self.size = size self.condition = threading.Condition() def producer(self): while True: with self.condition: while len(self.buffer) >= self.size: print("Buffer is full. Producer waits.") self.condition.wait() item = random.randint(1, 100) self.buffer.append(item) print(f"Produced {item}. Buffer: {self.buffer}") self.condition.notify_all() time.sleep(random.uniform(0.1, 0.5)) def consumer(self): while True: with self.condition: while not self.buffer: print("Buffer is empty. Consumer waits.") self.condition.wait() item = self.buffer.pop(0) print(f"Consumed {item}. Buffer: {self.buffer}") self.condition.notify_all() time.sleep(random.uniform(0.1, 0.5)) if __name__ == "__main__": problem = ProducerConsumerProblem(size=5) t_producer = threading.Thread(target=problem.producer, daemon=True) t_consumer = threading.Thread(target=problem.consumer, daemon=True) t_producer.start() t_consumer.start() t_producer.join() t_consumer.join() ``` **说明**： - 使用 `Condition` 对象来控制对共享资源（即缓冲区）的访问。 - 当缓冲区满时，生产者进入等待状态；当缓冲区为空时，消费者进入等待状态[^3]。 - `notify_all()` 方法用于唤醒所有正在等待的线程。 --- #### 方法二：使用 `queue.Queue` `queue.Queue` 是 Python 标准库中专门为生产者消费者问题设计的一个工具类，内置了必要的同步机制，因此更加简洁易用。 ```python from queue import Queue import threading import random import time def producer(queue): while True: item = random.randint(1, 100) queue.put(item) print(f"Produced {item}. Queue Size: {queue.qsize()}") time.sleep(random.uniform(0.1, 0.5)) def consumer(queue): while True: item = queue.get() print(f"Consumed {item}. Queue Size: {queue.qsize()}") queue.task_done() time.sleep(random.uniform(0.1, 0.5)) if __name__ == "__main__": q = Queue(maxsize=5) t_producer = threading.Thread(target=producer, args=(q,), daemon=True) t_consumer = threading.Thread(target=consumer, args=(q,), daemon=True) t_producer.start() t_consumer.start() t_producer.join() t_consumer.join() ``` **说明**： - `queue.Queue` 自动处理了所有的同步细节，包括缓冲区满或空的情况下的阻塞行为[^2]。 - `put` 和 `get` 方法分别用于向队列中添加和移除元素，且具有内置的锁机制以防止竞争条件。 --- ### 关键点解析 1. **缓冲区的作用**： - 缓冲区解耦了生产者和消费者之间的直接依赖关系，使得两者能够独立运行[^2]。 - 支持并发操作，允许生产者快速生成数据而无需等待消费者处理完毕。 2. **同步与互斥**： - 同步确保生产者和消费者按照正确的顺序工作，避免因缓冲区满或空而导致错误。 - 互斥保证同一时刻只有一个线程能修改共享资源（即缓冲区），从而避免数据损坏[^3]。 3. **性能优化**： - 设置合理的缓冲区大小可以平衡生产和消费的速度差异，减少不必要的等待时间。 ---