C++如何实现基于互斥锁的线程安全队列-C++-PHP中文网

直接用 std::queue 加 std::mutex 不够安全，因 front() 和 pop() 分离导致竞态窗口；需封装原子 try_pop（返回 optional 或输出参数），push 优先 emplace，阻塞 pop 必配 condition_variable 并正确 notify。

c++如何实现基于互斥锁的线程安全队列

为什么直接用 `std::queue` 加 `std::mutex` 不够安全

因为 std::queue::front() 和 std::queue::pop() 是两个分离操作，中间存在竞态窗口：线程A调用 front() 拿到引用后，线程B可能已把队首元素 pop() 掉，导致A后续访问 dangling 引用。这不是加锁粒度粗的问题，而是接口设计本身不支持原子“取并删”。

如何封装一个真正线程安全的 pop 操作

必须把“获取值 + 移除元素”合并为一个原子操作，且避免返回引用（防止悬垂）。典型做法是传入一个输出参数或返回 std::optional<t></t>（C++17起）：

template<typename t>
class threadsafe_queue {
    mutable std::mutex mtx_;
    std::queue<t> queue_;
public:
    bool try_pop(T& value) {
        std::lock_guard<:mutex> lk(mtx_);
        if (queue_.empty()) return false;
        value = std::move(queue_.front());  // 移动语义减少拷贝
        queue_.pop();
        return true;
    }

    // C++17 推荐写法，更清晰表达“可能无值”
    std::optional<t> try_pop() {
        std::lock_guard<:mutex> lk(mtx_);
        if (queue_.empty()) return std::nullopt;
        T val = std::move(queue_.front());
        queue_.pop();
        return val;
    }
};</:mutex></t></:mutex></t></typename>

不要返回 T& 或 const T& —— 锁一释放，引用就失效
用 std::move 避免不必要的深拷贝，尤其对大对象或非 trivial 类型
函数名带 try_ 前缀，明确提示调用者需检查是否成功

push 操作看似简单，但要注意移动语义和异常安全

push 虽然只有一行，但若 T 的拷贝/移动构造可能抛异常，而你又在持有锁时调用它，会导致锁长期被占，甚至死锁风险（比如异常传播中析构函数再尝试加锁）。

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

优先使用 push(T&&) 重载，接收右值并 move 构造入队
如果必须支持左值，用 const T& + emplace 替代直接 push，把构造过程延迟到队列内部（减少锁内耗时）
实际项目中建议用 emplace 系列：它直接在队列内存中构造对象，避免临时对象+拷贝两步

示例：

void push(const T& item) {
    std::lock_guard<:mutex> lk(mtx_);
    queue_.emplace(item);  // 而不是 queue_.push(item)
}

void push(T&& item) {
    std::lock_guard<:mutex> lk(mtx_);
    queue_.emplace(std::move(item));
}</:mutex></:mutex>

阻塞式 pop 怎么做才不浪费 CPU 且可中断

不能用 while 循环加 try_pop + std::this_thread::yield()，那是忙等，吃满 CPU。正确方式是配合 std::condition_variable：

void wait_and_pop(T& value) {
    std::unique_lock<:mutex> lk(mtx_);
    cond_.wait(lk, [this]{ return !queue_.empty(); }); // 自动释放锁、唤醒后重新加锁
    value = std::move(queue_.front());
    queue_.pop();
}

// 可中断版本：加超时或中断令牌（C++20 <code>std::stop_token</code>）
bool wait_and_pop_for(T& value, std::chrono::milliseconds timeout) {
    std::unique_lock<:mutex> lk(mtx_);
    if (!cond_.wait_for(lk, timeout, [this]{ return !queue_.empty(); }))
        return false;
    value = std::move(queue_.front());
    queue_.pop();
    return true;
}</:mutex></:mutex>