Python多线程编程：同步问题实例

原创淡淡的烟草味﹌ 2025-01-19 12:45 5阅读 0赞

在Python多线程编程中，同步问题主要涉及到共享资源的访问控制。以下是一个简单的同步问题实例：

### 实例：生产者-消费者模型

假设我们有两个线程：
1. 生产者（producer）：负责生成产品，并将其放入队列。
2. 消费者（consumer）：从队列中取出产品进行使用。

为了实现同步，我们可以使用Python的锁（Lock）或者信号量（Semaphore）。

下面是一个使用`threading.Lock()`的简单生产者-消费者模型：

```python
import threading

# 创建一个共享锁
lock = threading.Lock()

def producer():
    for _ in range(10):  # 假设能生成10个产品
        with lock:  # 获取锁，确保数据的一致性
            print(f"生产者创建产品{_''}}")
            time.sleep(0.1)  # 模拟生产过程中的延迟

def consumer():
    while True:
        with lock:  # 获取锁，确保从队列中取出的是最新的产品
            if lock.acquire(False):  # 如果没有其他线程获取锁，我们就成功获取了锁
                print(f"消费者消费产品{lock.release()}}")
                time.sleep(0.2)  # 模拟产品被使用和释放的延迟
            else:  # 如果其他线程已经获得了锁，我们需要等待锁释放
                print("锁已获得，等待释放...")
                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()
```

在这个例子中，生产者线程和消费者线程通过共享的锁来实现同步。这样就可以确保在任何时候，只有一个线程可以修改共享资源。