python多线程并发锁

在 Python 中，多个线程同时访问共享资源时可能会导致数据竞争和不一致的结果。为了避免这种情况，可以使用锁机制来实现线程的同步。

Python 中的锁分为两种类型：互斥锁和信号量。互斥锁在同一时刻只允许一个线程访问共享资源，而信号量则允许多个线程同时访问共享资源，但是可以限制同时访问资源的线程数量。

以下是互斥锁和信号量的使用示例：

1、互斥锁
互斥锁通过 acquire() 和 release() 方法来实现锁的获取和释放。

import threading

lock = threading.Lock()

def func():
    lock.acquire()
    try:
        # 访问共享资源
    finally:
        lock.release()

在这个示例中，我们首先创建了一个 Lock 对象，然后在多个线程中使用 acquire() 方法获取锁，try/finally 块内访问共享资源，最后使用 release() 方法释放锁。

2、信号量
信号量通过 acquire() 和 release() 方法来实现锁的获取和释放。可以通过 Semaphore 类来创建信号量对象。

import threading

semaphore = threading.Semaphore(2)

def func():
    semaphore.acquire()
    try:
        # 访问共享资源
    finally:
        semaphore.release()

在这个示例中，我们首先创建了一个 Semaphore 对象，限制最多有两个线程可以同时访问共享资源，然后在多个线程中使用 acquire() 方法获取信号量，try/finally 块内访问共享资源，最后使用 release() 方法释放信号量。

需要注意的是，在使用锁机制时需要小心死锁问题，即多个线程相互等待对方释放锁而无法继续执行的情况。可以通过避免多个锁的嵌套使用和按照固定的顺序获取锁来避免死锁。