不能直接用 std::queue 做非阻塞任务队列,因其无 try_pop()/try_push() 语义,空时 pop() 会崩溃,且单线程下加锁冗余;需自实现环形缓冲区,支持无锁、o(1)、移动语义及异常安全。

为什么不能直接用 std::queue 做非阻塞任务队列?
因为 std::queue 本身不提供“尝试取但不等待”的语义,pop() 在空时会崩溃或未定义行为,而你又不想加锁(单线程场景下锁是冗余开销)。真正需要的是带 try_pop() 和 try_push() 的结构——它得自己管理内存、避免动态分配、支持移动语义。
用 std::vector + 双索引实现环形缓冲区
这是最轻量、最可控的方式:预分配固定大小的 std::vector,用 head 和 tail 索引模拟 FIFO。所有操作 O(1),无锁,无异常抛出(若禁用异常),且能完美支持 move-only 类型(如 std::function<void></void>)。
-
push()成功返回true,满则返回false(非阻塞核心) -
pop()成功返回true并将值 move 出来,空则返回false - 必须用
std::move转移元素,否则拷贝可能失败或低效 - 容量建议设为 2 的幂(便于位运算取模),但用
% capacity更直观安全
template<typename t>
class NonBlockingFifo {
std::vector<t> buf;
size_t head = 0, tail = 0;
size_t capacity;
<p>public:
explicit NonBlockingFifo(size_t cap) : buf(cap), capacity(cap) {}</p>
<pre class="brush:php;toolbar:false;">bool try_push(T&& item) {
size_t next_tail = (tail + 1) % capacity;
if (next_tail == head) return false; // full
buf[tail] = std::move(item);
tail = next_tail;
return true;
}
bool try_pop(T& out) {
if (head == tail) return false; // empty
out = std::move(buf[head]);
head = (head + 1) % capacity;
return true;
}
};
如何安全地存 std::function<void></void>?
这是典型使用场景,但要注意:默认构造的 std::function 占用约 24–32 字节,且内部可能触发小对象优化(SOO)或堆分配。在环形缓冲区中,只要 std::vector<t></t> 的 T 是可移动的,就完全没问题;但需确保 T 的移动构造/赋值不抛异常(加 noexcept 声明更稳妥)。
- 声明队列时写
NonBlockingFifo<:function>></:function>即可 - 推入 lambda 或 bind 表达式时,用
std::move包裹(q.try_push(std::move(cb))) - 不要存引用捕获的 lambda 到队列里——生命周期很可能短于队列
- 如果任务函数可能抛异常,应在调用前用
try/catch封装,队列本身不处理异常
常见误用和边界坑点
这个结构看似简单,但几个地方一错就导致静默错误或 crash:
- 忘记初始化
head/tail为 0 → 读写越界 - 用
size()计算长度时写成(tail - head)(无符号溢出)→ 正确是(tail - head + capacity) % capacity - 在
try_pop()中传入已析构对象的引用 → 必须确保out参数生命周期覆盖调用 - 多线程误用(哪怕只读)→ 这个实现严格单线程,
head/tail都没原子性 - 容量设为 0 →
vector构造合法但后续取模除零 → 初始化时应 assert(cap > 0)
真正难的不是写出来,而是让每个 push/pop 都明确知道“失败了怎么办”——比如任务被丢弃、还是退回到线程本地队列、或是触发告警。这部分逻辑不在队列里,但必须由使用者闭环。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











