并发编程难题：Python多线程及锁机制实践案例？

原创爱被打了一巴掌 2025-02-20 15:42 0阅读 0赞

在Python中，处理并发和锁定机制是一个常见的挑战。下面提供一个实际案例，我们将通过编写一个简单的生产者消费者模型来展示这个过程。

首先，我们需要导入必要的模块：

```python
import threading
from queue import Queue
```

然后定义生产者、消费者线程以及相应的函数：

```python
class ProducerThread(threading.Thread):
    def __init__(self, queue):
        super(ProducerThread, self).__init__()
        self.queue = queue

def run(self):
        for _ in range(10):  # 生产10个元素
            item = "Product-%d" % (_ + 1))
            self.queue.put(item)
            print(f"Producer: {item} added to queue")

class ConsumerThread(threading.Thread):
    def __init__(self, queue):
        super(ConsumerThread, self).__init__()
        self.queue = queue

def run(self):
        while True:  # 消费线程一直运行
            item = self.queue.get()  # 获取队列中的元素
            print(f"Consumer: {item} consumed from queue")

if __name__ == "__main__":
    producer_queue = Queue()
    consumer_queue = Queue()

producer_thread = ProducerThread(producer_queue)
    consumer_thread = ConsumerThread(consumer_queue)

producer_thread.start()
    consumer_thread.start()

producer_thread.join()
    consumer_thread.join()

```

这个例子中，生产者线程在`Queue()`中添加10个元素（模拟产品），然后消费者线程从队列中获取并消费这些产品。

通过这种方式，你不仅展示了Python多线程的使用，还实践了锁机制来保证数据的一致性。