C++怎么实现线程安全的队列-C++-PHP中文网

std::queue 本身不线程安全，多线程读写需加锁；应封装带 std::mutex 成员的线程安全队列类，所有操作加锁，empty() 必须加锁，推荐用 try_pop 和 condition_variable 实现阻塞式 pop。

c++怎么实现线程安全的队列

std::queue 本身不线程安全，必须加锁

直接用 std::queue 在多线程里读写——比如一个线程 push、另一个线程 pop——会触发未定义行为。它内部没有同步机制，底层容器（如 std::deque）的迭代器失效、内存重分配等操作在并发下极易崩溃或读到脏数据。

常见错误现象包括：程序随机 crash、pop 返回垃圾值、empty() 和实际大小不一致、死锁（如果锁粒度没设计好）。

别试图靠“只读不写”或“生产者/消费者严格错开时间”来规避——编译器重排、CPU缓存不一致会让这种假设瞬间失效
锁对象必须和队列实例生命周期一致；不能用局部 std::mutex 或静态锁保护多个不同队列
优先用 std::lock_guard 自动管理，避免手动 unlock() 遗漏

封装一个带锁的 queue 模板类最稳妥

自己封装一层比每次调用都手写锁更安全、不易漏。关键点是把 std::mutex 作为成员变量，所有访问队列的操作都包裹在临界区内。

示例核心结构：

template<typename t>
class ThreadSafeQueue {
private:
    std::queue<t> q_;
    mutable std::mutex mtx_;

public:
    void push(const T& val) {
        std::lock_guard<:mutex> lock(mtx_);
        q_.push(val);
    }

    bool try_pop(T& val) {
        std::lock_guard<:mutex> lock(mtx_);
        if (q_.empty()) return false;
        val = std::move(q_.front());
        q_.pop();
        return true;
    }

    bool empty() const {
        std::lock_guard<:mutex> lock(mtx_);
        return q_.empty();
    }
};</:mutex></:mutex></:mutex></t></typename>

try_pop 比直接 pop 更安全：避免空队列时抛异常或未定义行为
empty() 必须加锁——否则返回 true 后另一线程立刻 push，紧接着 try_pop 就会失败
不要提供 front() 独立接口：它和 pop() 分离会导致典型的“检查后使用”（TOCTOU）竞态

用 std::condition_variable 实现阻塞式 pop

纯 try_pop 需要轮询，浪费 CPU。想让消费者线程在空时自动挂起、有数据时被唤醒，就得加 std::condition_variable。

C++14

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

下载

关键改动点：

把 std::mutex 和 std::condition_variable 一起用，wait 必须传入已锁定的 std::unique_lock
notify_one() 放在 push 末尾（有新数据就通知一个等待者），notify_all() 仅在需唤醒全部消费者时用（比如关闭信号）
wait 的 lambda 条件必须是 !q_.empty()，不能只靠 notify——因为存在虚假唤醒

阻塞 pop 示例：

void wait_and_pop(T& val) {
    std::unique_lock<:mutex> lock(mtx_);
    cond_.wait(lock, [this]{ return !q_.empty(); });
    val = std::move(q_.front());
    q_.pop();
}</:mutex>