C++如何实现简单的多阶段多线程流水线执行模型-C++-PHP中文网

最小可行模型是用std::thread+std::queue+std::mutex搭建三阶段流水线骨架，每个阶段封装为独立函数，仅通过专属阻塞队列单向传递数据，避免共享状态与竞态。

c++如何实现简单的多阶段多线程流水线执行模型

什么是多阶段流水线的最小可行模型

多阶段流水线不是非得用 Actor 模型或复杂调度器才能实现。C++ 里用 std::thread + std::queue + std::mutex 就能搭出可运行的骨架，关键是每个阶段只做一件事、只读前一阶段的输出、只写后一阶段的输入——避免共享状态和竞态。

常见错误是让一个线程既消费又生产多个队列，或者用全局变量传递中间数据，结果出现数据错乱或死锁。正确做法是把每个阶段封装成独立函数，通过专属的 std::queue 连接，且每个队列只由上游写、下游读。

如何用 blocking_queue 实现阶段间同步

标准库没有阻塞队列，但几行代码就能补上：用 std::queue + std::mutex + std::condition_variable 封装一个 blocking_queue。它比裸用 std::queue 安全得多，避免“忙等”或“空取”。

关键点：

pop() 必须在 cv.wait() 中检查队列是否非空，否则可能唤醒后队列已空
每次 push() 后调用 cv.notify_one()（不是 notify_all），减少不必要的唤醒开销
构造时指定容量上限，防止内存无限增长（尤其处理慢、生产快时）

示例片段：

template<typename t>
class blocking_queue {
    std::queue<t> q_;
    mutable std::mutex mtx_;
    std::condition_variable cv_;
    size_t capacity_;
public:
    blocking_queue(size_t cap = 1024) : capacity_(cap) {}
    void push(const T& x) {
        std::lock_guard<:mutex> lk(mtx_);
        while (q_.size() >= capacity_) cv_.wait(lk);
        q_.push(x);
        cv_.notify_one();
    }
    T pop() {
        std::unique_lock<:mutex> lk(mtx_);
        cv_.wait(lk, [this]{ return !q_.empty(); });
        T x = std::move(q_.front());
        q_.pop();
        return x;
    }
};</:mutex></:mutex></t></typename>