多生产者/消费者线程共享缓冲区实现遇死锁问题求助

嘿，看起来你在生产者消费者模型里碰到了条件变量导致的死锁问题——这可是多线程编程里的经典坑！我之前帮不少人排查过类似问题，先给你梳理下常见的死锁诱因，再给你修正后的伪代码思路吧。

• 条件变量等待前未持有互斥锁：如果调用wait()时没拿到锁，会直接破坏线程安全，甚至触发死锁。
• 用if而非while检查等待条件：条件变量存在伪唤醒（spurious wakeup）的可能，或者被唤醒时缓冲区状态已经不符合操作要求，必须循环校验。
• 单一条件变量混用唤醒逻辑：比如用同一个条件变量同时通知生产者和消费者，会导致线程被错误唤醒后白等，最终引发死锁。
• 唤醒时机错误：比如还没修改缓冲区状态就唤醒其他线程，导致唤醒的线程看到的还是旧状态，继续休眠。

先定义共享资源与同步工具：

mutex buffer_mtx;
condition_variable cv_not_full;  // 专门通知生产者：缓冲区有剩余空间了
condition_variable cv_not_empty; // 专门通知消费者：缓冲区有元素了
queue<int> buffer;
const int MAX_BUFFER_CAPACITY = 10; // 缓冲区最大容量

生产者线程逻辑 #

void producer_thread() {
    while (true) {
        // 生成待放入的元素（模拟耗时生产）
        int item = generate_new_item();

        unique_lock<mutex> lock(buffer_mtx);
        // 循环等待：直到缓冲区有剩余空间
        while (buffer.size() == MAX_BUFFER_CAPACITY) {
            cv_not_full.wait(lock); // 等待时自动释放锁，被唤醒后重新获取
        }
        // 放入元素到缓冲区
        buffer.push(item);
        cout << "生产者放入元素，当前缓冲区大小：" << buffer.size() << endl;
        // 唤醒消费者：现在缓冲区非空了
        cv_not_empty.notify_one();
        // 锁会在unique_lock析构时自动释放
    }
}

消费者线程逻辑 #

void consumer_thread() {
    while (true) {
        unique_lock<mutex> lock(buffer_mtx);
        // 循环等待：直到缓冲区有元素可取
        while (buffer.empty()) {
            cv_not_empty.wait(lock);
        }
        // 取出元素
        int item = buffer.front();
        buffer.pop();
        cout << "消费者取出元素，当前缓冲区大小：" << buffer.size() << endl;
        // 唤醒生产者：现在缓冲区有剩余空间了
        cv_not_full.notify_one();
        // 提前释放锁，避免持有锁时做耗时的元素处理
        lock.unlock();
        // 处理取出的元素（模拟耗时消费）
        process_item(item);
    }
}

• 拆分条件变量：用cv_not_full和cv_not_empty分别对应生产者和消费者的等待条件，避免线程被错误唤醒。
• while循环校验条件：彻底解决伪唤醒问题，确保线程被唤醒时缓冲区状态确实满足操作要求。
• 正确的唤醒时机：生产者放入元素后才唤醒消费者，消费者取出元素后才唤醒生产者，保证线程间的协作逻辑闭环。
• 及时释放锁：消费者处理元素前主动释放锁，避免长时间持有锁导致其他线程阻塞，降低死锁风险。

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