不能直接用 std::queue + mutex 做调度器，因其无阻塞等待能力，需配合 std::condition_variable 实现 wait/notify；必须用 while 循环检查队列非空防虚假唤醒，且 stop 后需 notify_all 并确保优雅关闭。
为什么不能直接用 std::queue + mutex 做调度器
因为 std::queue 本身不带阻塞等待能力，生产者 push 后消费者得轮询或手动 sleep，浪费 CPU；而真正调度器需要「有任务就立刻处理，没任务就挂起」。必须配合条件变量（std::condition_variable）实现 wait/notify 语义。
常见错误是只加 std::mutex 锁但忘了在 wait() 前检查队列是否为空，导致虚假唤醒后 pop 空队列——程序崩溃或未定义行为。
- 每次
wait()必须放在while (queue.empty())循环里，不能用if -
std::queue不支持移动语义批量消费，如果任务类型大（比如含std::vector），建议用std::deque或直接存储std::function<void>&&</void> - 避免在持有锁时调用用户回调（可能死锁或抛异常），pop 后立即 unlock 再执行
如何写一个线程安全的单队列调度器类
核心是封装 std::queue、std::mutex、std::condition_variable 和停止标志。关键不是“能跑”，而是「谁负责 stop、怎么保证所有 pending 任务被执行完」。
class SimpleScheduler {
std::queue<std::function<void()>> tasks_;
std::mutex mtx_;
std::condition_variable cv_;
std::atomic<bool> stop_{false};
public:
void post(std::function<void()> task) {
std::lock_guard<std::mutex> lk(mtx_);
tasks_.push(std::move(task));
cv_.notify_one(); // 注意：notify_one 足够，notify_all 浪费
}
void run() {
while (true) {
std::function<void()> task;
{
std::unique_lock<std::mutex> lk(mtx_);
cv_.wait(lk, [this] { return stop_ || !tasks_.empty(); });
if (stop_ && tasks_.empty()) break;
task = std::move(tasks_.front());
tasks_.pop();
} // unlock 自动发生
task(); // 执行在锁外
}
}
void stop() {
stop_.store(true, std::memory_order_relaxed);
cv_.notify_all(); // 必须 notify_all，否则多个 worker 可能卡住
}
};
注意：stop() 之后调用 run() 的线程必须能退出；若用多个消费者线程，需把 run() 改为循环体并统一管理生命周期。
立即学习“C++免费学习笔记（深入）”；
组合式C++代码评审方案，融合静态分析、AI推理、多轮迭代评审和C++专项检查，适用于PR审查、增量代码审查、全项目评审和代码质量评分，触发词包括review cpp、cpp代码评审、C++review、代码审查。
多消费者场景下容易漏掉的同步点
单队列多线程消费时，stop_ 标志和 cv_.notify_all() 的顺序必须严格：先 store true，再 notify，否则某个线程可能在 notify 前被 wait 挂起，永远收不到信号。
- 不要用
std::memory_order_seq_cst过度保护——std::atomic<bool></bool>默认就是 seq_cst，够用 - 如果调度器要支持「优雅关闭」（等当前任务执行完再停），就得加一个正在运行中的计数器（
std::atomic<int> running_{0}</int>），并在 task 执行前后增减 - 避免在
post()里做 heavy 拷贝：传入的std::function<void></void>如果捕获了大对象，建议用std::move或显式转为右值引用参数
实际部署时要注意的兼容性细节
Windows 下 MinGW 或旧版 MSVC（如 VS2015）对 std::condition_variable::wait() 的超时重载支持不一致，如果后续要加 timeout 版本的 try_run_for()，优先用 wait_for() 而非 wait_until()，并检查编译器版本。
另外，C++17 起 std::queue 的移动构造函数才真正高效，若目标环境是 C++14，建议在 post() 中直接 tasks_.emplace(std::move(task)) 而非 push，减少一次拷贝。
真正麻烦的是异常传播——如果用户 callback 抛异常且没被捕获，整个消费者线程会 terminate。生产环境务必在外层 try/catch 包裹 task() 并记录日志，而不是放任线程消失。
