Python并发编程：理解和使用multiprocessing模块案例

原创本是古典何须时尚 2025-01-24 03:21 2阅读 0赞

在Python中，多线程（threading）和多进程（multiprocessing）是两种常见的并发编程方式。下面我们将通过一个简单案例来理解并使用`multiprocessing模块`。

### 简单例子：生产者消费者模型

假设我们有以下两个类：

1. Productor类
2. Consumer类

Productor类负责生成产品，并将其发送给Consumer类。

```python
import multiprocessing

# 1. Producer class
class Producer(multiprocessing.Process):
    def __init__(self, queue):
        super(Producer, self).__init__()
        self.queue = queue

# 生产函数，模拟生产过程
    def produce(self, num_products):
        for _ in range(num_products):
            product = "Product {}".format(_)
            print(f"Produced: {product}, Queued: {self.queue.put(product)})")
        print("Production complete.")

# 2. Consumer class
class Consumer(multiprocessing.Process):
    def __init__(self, queue):
        super(Consumer, self).__init__()
        self.queue = queue

# 消费函数，模拟消费过程
    def consume(self):
        while True:
            product = self.queue.get()
            print(f"Consumed: {product}, Queued: {self.queue.put(product)})")
            if not self.queue.empty():
                break  # 如果队列非空，则跳出循环
        print("Consumption complete.")

# 主程序，创建生产者和消费者进程
if __name__ == "__main__":
    queue = multiprocessing.Queue()  # 创建一个共享队列

producer = Producer(queue)  # 创建生产者进程并传递队列
    consumer = Consumer(queue)  # 创建消费者进程并传递队列

producer.produce(10)  # 生产10个产品
    consumer.consume()  # 消费这些产品

```

当你运行这个程序时，你会看到生产者（Producer）不断生成产品，并将其放入共享队列（Queue）。然后，消费者（Consumer）从队列中获取产品并进行消费。

这就是使用`multiprocessing模块`实现的简单并发生产者消费者模型。