C++实现异步任务调度队列 _ 线程池与工作线程协作模式【源码】-C++-PHP中文网

std::queue本身不线程安全，多线程并发push/pop会引发数据竞争，导致任务丢失、崩溃或死锁；必须用mutex+condition_variable封装为阻塞队列，并配合谓词等待与move语义保障安全高效。

c++实现异步任务调度队列 _ 线程池与工作线程协作模式【源码】

为什么 std::thread + std::queue 不能直接当异步调度队列用

因为裸队列没有线程安全保证，std::queue 本身不提供原子操作，多个工作线程同时 push 或 pop 会触发数据竞争，轻则结果错乱，重则程序崩溃。你看到的“任务丢失”“死锁在 empty() 后的 pop()”“偶尔 segfault”，大概率是这个原因。

必须加同步机制，但别一上来就锁整个队列——那会变成串行执行，线程池就白搭了。正确做法是：用 std::mutex + std::condition_variable 封装一个线程安全的阻塞队列，让空闲线程能挂起等待，而不是忙等。

避免用 std::lock_guard 包裹整个 while 循环体，否则每次循环都抢锁释放锁，开销大
wait() 必须配合谓词（lambda）使用，防止虚假唤醒导致 pop() 在空队列上调用
不要把 std::function<void></void> 直接存进队列——它有拷贝开销，且无法 move-only 类型（如带 unique_ptr 的 lambda）

如何设计线程安全的 task_queue（带 move 语义支持）

核心是把任务包装成可移动、不可拷贝的类型，再用 std::queue<:function>></:function> 配合 std::move 转移所有权。标准库允许 move std::function，所以可以安全地从队列中取出并执行。

示例关键片段：

class task_queue {
    std::queue<:function>> m_tasks;
    mutable std::mutex m_mutex;
    std::condition_variable m_cv;
    std::atomic<bool> m_shutdown{false};

public:
    void push(std::function<void> task) {
        std::lock_guard<:mutex> lk(m_mutex);
        m_tasks.push(std::move(task));
        m_cv.notify_one(); // 只唤醒一个线程，避免惊群
    }

    std::function<void> pop() {
        std::unique_lock<:mutex> lk(m_mutex);
        m_cv.wait(lk, [this] { return m_shutdown || !m_tasks.empty(); });
        if (m_shutdown && m_tasks.empty()) return {};
        auto task = std::move(m_tasks.front());
        m_tasks.pop();
        return task;
    }
};
</:mutex></void></:mutex></void></bool></:function>