读者写者问题c++代码

下面是一个使用互斥锁和条件变量解决读者写者问题的C++代码示例：

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
using namespace std;

mutex mtx;
condition_variable cv;
int read_count = 0;
bool writing = false;

void reader(int id) {
    while (true) {
        unique_lock<mutex> lock(mtx);
        // 等待写者释放锁
        while (writing) {
            cv.wait(lock);
        }
        // 读者进程数加一
        read_count++;
        cout << "Reader " << id << " is reading" << endl;
        // 读者进程数减一
        read_count--;
        // 如果没有读者进程了，通知写者进程
        if (read_count == 0) {
            cv.notify_one();
        }
        // 释放锁
        lock.unlock();
        // 读者进程阻塞一段时间
        this_thread::sleep_for(chrono::milliseconds(100));
    }
}

void writer(int id) {
    while (true) {
        unique_lock<mutex> lock(mtx);
        // 等待其他读者或写者释放锁
        while (writing || read_count > 0) {
            cv.wait(lock);
        }
        // 标记为正在写入
        writing = true;
        cout << "Writer " << id << " is writing" << endl;
        // 标记为不在写入
        writing = false;
        // 通知其他读者或写者可以获取锁了
        cv.notify_all();
        // 释放锁
        lock.unlock();
        // 写者进程阻塞一段时间
        this_thread::sleep_for(chrono::milliseconds(200));
    }
}

int main() {
    thread r1(reader, 1);
    thread r2(reader, 2);
    thread r3(reader, 3);
    thread w1(writer, 1);
    thread w2(writer, 2);
    r1.join();
    r2.join();
    r3.join();
    w1.join();
    w2.join();
    return 0;
}

在上面的代码中，读者进程和写者进程都是无限循环的，每次循环都会先获取互斥锁，然后判断是否可以访问共享资源，如果不能访问，则等待条件变量通知。读者进程在访问共享资源之前需要增加读者进程数，访问完后需要减少读者进程数，如果没有读者进程了，则通知写者进程。写者进程在访问共享资源之前需要等待读者进程和其他写者进程释放锁，访问完成后需要通知其他读者进程和写者进程可以访问共享资源了。

需要注意的是，在实际应用中，需要根据具体情况来合理设置互斥锁和条件变量。此外，需要考虑到多线程并发访问可能会导致的竞争条件、死锁、优先级反转等问题，需要进行充分的测试和优化。