读写锁通过区分读共享、写独占机制，提升Python多线程下读密集场景的并发性能，保障数据一致性。

在Python多线程编程中，多个线程同时访问共享资源时容易引发数据竞争问题。当资源涉及频繁读取和少量写入时，使用读写锁（Reader-Writer Lock）能显著提升并发性能。读写锁允许多个读线程同时访问资源，但写操作必须独占资源，避免脏读或写冲突。

读写锁的基本原理

读写锁的核心思想是区分读操作和写操作的权限：

• 读锁（共享锁）：多个线程可同时持有，适用于只读操作。
• 写锁（独占锁）：仅允许一个线程持有，其他读写线程必须等待。

这种机制保障了数据一致性的同时，提高了读密集场景下的并发效率。

使用threading模块实现读写锁

Python标准库threading未提供原生读写锁，但可通过RLock和条件变量Condition手动实现：

import threading
class ReadWriteLock:
def init(self):
self._read_ready = threading.Condition(threading.RLock())
self._readers = 0
def acquire_read(self):
    self._read_ready.acquire()
    try:
        self._readers += 1
    finally:
        self._read_ready.release()

def release_read(self):
    self._read_ready.acquire()
    try:
        self._readers -= 1
        if self._readers == 0:
            self._read_ready.notifyAll()
    finally:
        self._read_ready.release()

def acquire_write(self):
    self._read_ready.acquire()
    while self._readers > 0:
        self._read_ready.wait()

def release_write(self):
    self._read_ready.release()

说明：

• acquire_read：增加读者计数，无需等待。
• release_read：减少计数，若无读者则唤醒等待的写线程。
• acquire_write：阻塞直到所有读线程释放锁。
• release_write：释放锁并通知其他线程。

实际使用示例

假设有一个共享缓存对象，多个线程读取，少数线程更新：

rw_lock = ReadWriteLock()
cache = {}
def reader(name):
rw_lock.acquire_read()
print(f"{name} 正在读取: {cache}")
rw_lock.release_read()
def writer(name, key, value):
rw_lock.acquire_write()
print(f"{name} 正在写入: {key}={value}")
cache[key] = value
rw_lock.release_write()
多线程测试
threads = []
for i in range(3):
threads.append(threading.Thread(target=reader, args=(f"Reader-{i}",)))
threads.append(threading.Thread(target=writer, args=("Writer-1", "x", 1)))
for t in threads:
t.start()
for t in threads:
t.join()

输出会显示多个读操作并发执行，而写操作独占执行，确保数据安全。

第三方库简化实现

也可使用readwrite_lock等第三方包：

pip install readwrite-lock

from readwrite_lock import RWLock
lock = RWLock()
r_lock = lock.read_lock()
w_lock = lock.write_lock()
使用
r_lock.acquire()
执行读操作
r_lock.release()