直接用 std::queue 加 std::mutex 不够安全，因 front() 和 pop() 分离导致竞态窗口；需封装原子 try_pop（返回 optional 或输出参数），push 优先 emplace，阻塞 pop 必配 condition_variable 并正确 notify。
为什么直接用 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<std::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<std::mutex> lk(mtx_);
if (queue_.empty()) return std::nullopt;
T val = std::move(queue_.front());
queue_.pop();
return val;
}
};
- 不要返回
T&或const T&—— 锁一释放，引用就失效 - 用
std::move避免不必要的深拷贝，尤其对大对象或非 trivial 类型 - 函数名带
try_前缀，明确提示调用者需检查是否成功
push 操作看似简单，但要注意移动语义和异常安全
push 虽然只有一行，但若 T 的拷贝/移动构造可能抛异常，而你又在持有锁时调用它，会导致锁长期被占，甚至死锁风险（比如异常传播中析构函数再尝试加锁）。
- 优先使用
push(T&&)重载，接收右值并 move 构造入队 - 如果必须支持左值，用
const T&+emplace替代直接push，把构造过程延迟到队列内部（减少锁内耗时） - 实际项目中建议用
emplace系列：它直接在队列内存中构造对象，避免临时对象+拷贝两步
示例：
立即学习“C++免费学习笔记（深入）”；
void push(const T& item) {
std::lock_guard<std::mutex> lk(mtx_);
queue_.emplace(item); // 而不是 queue_.push(item)
}
void push(T&& item) {
std::lock_guard<std::mutex> lk(mtx_);
queue_.emplace(std::move(item));
}
阻塞式 pop 怎么做才不浪费 CPU 且可中断
不能用 while 循环加 try_pop + std::this_thread::yield()，那是忙等，吃满 CPU。正确方式是配合 std::condition_variable：
void wait_and_pop(T& value) {
std::unique_lock<std::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<std::mutex> lk(mtx_);
if (!cond_.wait_for(lk, timeout, [this]{ return !queue_.empty(); }))
return false;
value = std::move(queue_.front());
queue_.pop();
return true;
}
-
std::condition_variable::wait必须配std::unique_lock，不能用std::lock_guard - 谓词 lambda 必须是「真实条件」，不能只写
!queue_.empty()字面量——防止虚假唤醒后直接执行 pop 导致崩溃 - 别忘了在
push后调用cond_.notify_one()或notify_all()
条件变量那部分最容易漏掉 notify，或者 notify 放错位置（比如锁外 notify），结果就是线程永远卡在 wait。
