多个读者的一致性读取

在多个读者的一致性读取中，可以使用共享锁（Shared Lock）来保证数据的一致性。以下是一个使用共享锁的代码示例：

import threading

# 共享资源
shared_data = []  # 假设 shared_data 是一个共享的数据结构
readers = 0  # 记录当前读者数量
lock = threading.Lock()  # 用于保证共享资源的互斥访问

def read_data(reader_id):
    global readers
    lock.acquire()  # 获取锁，保证共享资源的互斥访问
    readers += 1
    if readers == 1:
        lock.acquire()  # 第一个读者获取独占锁，阻止其他写者的访问
    lock.release()  # 释放锁，允许其他读者的访问

    # 读取共享资源
    print(f"Reader {reader_id} reads data: {shared_data}")

    lock.acquire()  # 获取锁，保证修改读者数量的操作的互斥访问
    readers -= 1
    if readers == 0:
        lock.release()  # 最后一个读者释放独占锁，允许写者访问
    lock.release()  # 释放锁

def write_data(writer_id, data):
    lock.acquire()  # 获取锁，保证共享资源的互斥访问

    # 修改共享资源
    shared_data.append(data)
    print(f"Writer {writer_id} writes data: {data}")

    lock.release()  # 释放锁

# 创建多个读者线程和写者线程
num_readers = 5
num_writers = 2
threads = []

for i in range(num_readers):
    t = threading.Thread(target=read_data, args=(i,))
    threads.append(t)

for i in range(num_writers):
    t = threading.Thread(target=write_data, args=(i, f"Data{i}"))
    threads.append(t)

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

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

在这个示例中，通过使用 threading.Lock 锁对象来保证共享资源 shared_data 的互斥访问。读者在读取共享资源之前先获取共享锁，然后在读取完成后释放共享锁。写者在修改共享资源之前也需要获取共享锁，然后在修改完成后释放共享锁。这样可以保证读者和写者之间的互斥访问，从而实现多个读者的一致性读取。