扩展版读者-写者问题：文件遍历的多线程同步实现问询

结论：仅用原有的wrt和mutex无法实现该扩展场景 #

原经典读者-写者同步逻辑只解决了写者与读者互斥、读者间共享读取的基础问题，但完全满足不了这个扩展场景的核心要求：

• 没法保证所有读者读完当前文件全部分块后，写者才开始清空重写
• 无法协调每个读者仅读取指定分块，也做不到读者间的读取轮次对齐
• 没有机制跟踪当前轮次的读写状态，写者无法知晓所有读者是否完成当前轮次读取

可行实现方案（基于原同步原语+新增组件） #

需要在原有wrt（写者互斥锁）、mutex（读者计数保护锁）基础上，新增以下同步组件与状态变量：

新增全局状态变量（需用互斥锁保护） #

• int current_round = 0：记录当前读写轮次，写者完成一次写入后递增
• int readers_finished = 0：记录当前轮次已完成读取的读者数量
• bool file_ready = false：标记当前轮次文件是否写入完成、分块就绪
• struct ChunkInfo chunks[N]：存储当前轮次每个分块的起始位置、长度等元数据（N为读者数量）

新增条件变量 #

• pthread_cond_t cv_writer：写者等待所有读者完成当前轮次读取的条件变量
• pthread_cond_t cv_readers[N]：每个读者等待对应分块就绪的条件变量（也可复用一个全局条件变量配合轮次判断）

写者代码（C++伪代码） #

do {
    // 等待所有读者读完上一轮内容，获取写入权限
    wait(wrt);
    
    // 清空文件、写入新内容并分割为N个分块
    clear_file();
    write_new_content();
    split_into_chunks(chunks, N);
    
    // 更新轮次状态，标记文件就绪
    wait(mutex);
    current_round++;
    readers_finished = 0;
    file_ready = true;
    signal(mutex);
    
    // 唤醒所有等待的读者，通知新内容已就绪
    for (int i = 0; i < N; i++) {
        pthread_cond_signal(&cv_readers[i]);
    }
    
    // 释放写者锁，等待所有读者完成当前轮次
    signal(wrt);
    
    // 阻塞等待所有读者读完当前轮次
    wait(mutex);
    while (readers_finished < N) {
        pthread_cond_wait(&cv_writer, &mutex);
    }
    file_ready = false; // 标记当前轮次内容失效
    signal(mutex);

} while (true);

第i个读者代码（C++伪代码，i从0到N-1） #

int my_last_round = -1; // 记录自己已读取的最后一轮次

do {
    wait(mutex);
    // 等待当前轮次文件就绪，且自己未读过该轮次
    while (!file_ready || my_last_round == current_round) {
        pthread_cond_wait(&cv_readers[i], &mutex);
    }
    // 获取自己对应分块的信息
    ChunkInfo my_chunk = chunks[i];
    my_last_round = current_round;
    signal(mutex);
    
    // 执行分块读取操作
    read_chunk(my_chunk);
    
    // 标记自己完成读取，检查是否所有读者都完成
    wait(mutex);
    readers_finished++;
    if (readers_finished == N) {
        // 所有读者完成，唤醒写者开始下一轮写入
        pthread_cond_signal(&cv_writer);
    }
    signal(mutex);

} while (true);

关键逻辑说明 #

1. 轮次同步：通过current_round和my_last_round确保每个读者只读取当前轮次的对应分块，不会重复读取旧内容
2. 写者等待机制：写者写完新内容后，必须等readers_finished达到N，才会启动下一轮的清空写入
3. 分块协调：每个读者通过cv_readers[i]等待自己的分块就绪，确保写者完成全部写入后才开始读取
4. 互斥保护：所有全局状态变量的访问都通过mutex保护，避免竞态条件

内容的提问来源于stack exchange，提问作者Done