C++17多线程下自定义SafeQueue锁死超时后空队列调用front报错问题

核心问题根因 #

你遇到的空队列调用.front()报错、疑似锁死的问题本质是条件变量未处理虚假唤醒和多线程竞争场景，触发了未定义行为：
std::condition_variable的wait_for方法即使返回std::cv_status::no_timeout，也不代表队列一定有元素，两种常见场景会导致唤醒后队列仍为空：

• 操作系统触发的虚假唤醒，属于条件变量的标准允许行为
• 多个线程同时等待队列元素，其中一个线程先拿到锁取走了唯一的元素，后续被唤醒的线程拿到锁时队列已经为空

你当前的代码在wait_for返回后没有二次检查队列状态，直接访问.front()就会触发空队列访问报错，未定义行为可能表现为程序无响应、崩溃等，就是你观察到的锁死现象。

其他潜在问题 #

• put方法入参为非常量左值引用，无法传入临时对象、右值参数，使用场景受限
• get方法超时后返回默认构造的StoredType，若业务使用的类型无默认构造函数会编译失败，可根据业务需求调整为返回std::optional等方案
• 原代码中锁、条件变量、队列成员为公有属性，外部可直接操作破坏线程安全

修复后完整代码 #

#pragma once

#include <string>
#include <mutex>
#include <queue>
#include <condition_variable>
#include <chrono>
#include <iostream>
#include <utility>

template <typename StoredType>
class SafeQueue {
public:
    uint8_t empty();
    // 重载支持左值和右值传入
    void put(const StoredType& element);
    void put(StoredType&& element);
    StoredType get();
private:
    std::condition_variable ready;
    std::mutex queue_lock;
    std::queue<StoredType> safe_queue = {};
};


template <typename StoredType>
StoredType SafeQueue<StoredType>::get() {
    std::unique_lock<std::mutex> condition_lock(queue_lock);
    // 改用while循环，每次唤醒后都重新检查队列状态
    while (safe_queue.empty()) {
        if (ready.wait_for(condition_lock, std::chrono::seconds(20)) == std::cv_status::timeout) {
            // 超时返回默认对象，可根据需求改为抛出异常或返回std::optional
            return StoredType();
        }
    }
    // 走到这里队列一定非空，直接取元素即可
    StoredType element = safe_queue.front();
    safe_queue.pop();
    return element;
}

template <typename StoredType>
void SafeQueue<StoredType>::put(const StoredType& element) {
    std::lock_guard<std::mutex> put_guard(queue_lock);
    safe_queue.push(element);
    ready.notify_one();
}

template <typename StoredType>
void SafeQueue<StoredType>::put(StoredType&& element) {
    std::lock_guard<std::mutex> put_guard(queue_lock);
    safe_queue.push(std::move(element));
    ready.notify_one();
}

template <typename StoredType>
uint8_t SafeQueue<StoredType>::empty() {
    std::lock_guard<std::mutex> empty_guard(queue_lock);
    return safe_queue.empty() ? 1 : 0;
}

修复说明 #

1. 将wait_for外层的if判断改为while循环，每次唤醒后都重新检查队列是否为空，从根源避免虚假唤醒和多线程竞争导致的空队列访问问题
2. 把内部成员变量改为私有，避免外部直接操作队列、锁、条件变量破坏线程安全
3. 重载put方法支持右值参数，提升性能同时扩大使用场景
4. 简化empty方法的判断逻辑，直接复用std::queue的empty()方法，保留你要求的uint8_t返回值类型

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