多线程同步问题：Python中的锁和信号量实例

原创ゞ浴缸里的玫瑰 2025-02-25 04:39 61阅读 0赞

在Python中，你可以使用内置的`threading.Lock`来实现锁同步，以及`threading.Semaphore`来实现信号量。

下面分别给出这两个类的基本使用示例：

1. 锁（Lock）：
```python
import threading

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

def thread_function():
    # 获取锁
    lock.acquire()
    
    try:
        # 执行任务
        print("Thread is running...")
    finally:
        # 释放锁，让其他线程使用
        lock.release()

# 创建多个线程并执行函数
threads = []
for _ in range(5):  # 创建5个线程
    thread = threading.Thread(target=thread_function)
    threads.append(thread)  # 添加到线程列表

# 启动所有线程
for thread in threads:
    thread.start()

# 等待所有线程完成
for thread in threads:
    thread.join()
```

2. 信号量（Semaphore）：
```python
import threading

# 创建一个信号量，初始值为1
semaphore = threading.Semaphore(value=1)

def thread_function(semaphore):
    semaphore.acquire()  # 获取信号量

try:
        print("Thread is running...")  # 执行任务
    finally:
        semaphore.release()  # 释放信号量

# 创建多个线程并执行函数，每次最多获取一个信号量
threads = []
for _ in range(5):  # 创建5个线程
    thread = threading.Thread(target=thread_function, args=(semaphore,),))
    threads.append(thread)  # 添加到线程列表

# 启动所有线程
for thread in threads:
    thread.start()

# 等待所有线程完成
for thread in threads:
    thread.join()
```

以上就是Python中锁和信号量的实例，你可以根据实际需求选择合适的方式来同步多线程。