C++如何实现简单的基于单线程的非阻塞队列-C++-PHP中文网

std::queue不能直接用作非阻塞队列，因其pop()在空时触发未定义行为而非失败返回；非阻塞要求操作立即成功或失败并明确告知，需自实现try_push/try_pop接口，推荐基于std::deque或环形缓冲区的bounded版本。

c++如何实现简单的基于单线程的非阻塞队列

为什么不能直接用 `std::queue` 做非阻塞队列

std::queue 本身没有非阻塞语义，pop() 在空时会直接调用 front() 或 pop() 导致未定义行为（UB），不是“失败返回”，而是崩溃或读垃圾值。非阻塞的关键是：操作要么立即成功，要么立即失败并告知调用方——不等、不锁、不抛异常。

空队列调用 pop() 是未定义行为，不是抛异常
std::queue 底层容器（如 std::deque）的 empty() 和 pop_front() 不是原子组合，多线程下仍需额外同步；但即使单线程，你也需要明确区分“空”和“操作失败”
真正需要的是带返回值的 try_pop() 和 try_push() 接口

用 `std::deque` 手写一个线程安全无关但语义清晰的非阻塞队列

单线程场景下，不需要原子操作或锁，但要保证接口契约：所有操作立即返回，不阻塞，不崩溃。核心是把“是否成功”编码进返回值——推荐用 std::optional（C++17+）或布尔+引用输出参数。

用 std::deque<t></t> 作底层容器：支持 O(1) 头尾增删，比 std::vector 更适合队列语义
try_push(const T&) 总是成功（除非内存耗尽，此时 push_back() 抛 std::bad_alloc，但这是例外，不是业务逻辑阻塞）
try_pop(T& out) 返回 bool：仅当非空时复制 front 并 pop，否则不修改 out，返回 false
避免在 try_pop() 中返回 std::optional<t></t> —— 移动语义可能触发额外拷贝（尤其 T 非 trivial 类型），而引用输出更可控

template <typename t>
class nonblocking_queue {
    std::deque<t> data_;
public:
    void try_push(const T& x) { data_.push_back(x); }
    bool try_pop(T& out) {
        if (data_.empty()) return false;
        out = std::move(data_.front());  // 避免冗余拷贝
        data_.pop_front();
        return true;
    }
    bool empty() const { return data_.empty(); }
};</t></typename>

如果需要固定容量，怎么避免 push 也变成“非阻塞失败”

无限增长的队列在嵌入式或实时系统中不可接受。这时 try_push() 也必须可失败——即容量满时返回 false，不插入。

C函数速查手册（CHM版）

下载

用 std::array<t n></t> + 环形索引实现更省内存，但需手动管理头尾；std::deque 不支持容量限制，所以得自己加 max_size_ 成员
不要在构造时分配固定大小内存再用 std::deque——它仍会动态扩容；应改用 std::vector<t></t> + 环形缓冲区逻辑
关键点：判断 size() >= max_size_ 必须在 push 前，且 pop 后要允许 push 再进入

template <typename t>
class bounded_nonblocking_queue {
    std::vector<t> data_;
    size_t head_ = 0, tail_ = 0, size_ = 0;
    const size_t capacity_;
public:
    explicit bounded_nonblocking_queue(size_t cap) : data_(cap), capacity_(cap) {}
    bool try_push(const T& x) {
        if (size_ == capacity_) return false;
        data_[tail_] = x;
        tail_ = (tail_ + 1) % capacity_;
        ++size_;
        return true;
    }
    bool try_pop(T& out) {
        if (size_ == 0) return false;
        out = std::move(data_[head_]);
        head_ = (head_ + 1) % capacity_;
        --size_;
        return true;
    }
};</t></typename>

容易被忽略的移动语义和异常安全细节

非阻塞不等于无异常。如果 T 的移动构造函数抛异常，try_pop() 中 std::move(data_.front()) 可能中途失败，导致队列状态不一致（已 pop 但未赋值给 out）。单线程下虽不涉及并发，但正确性仍依赖强异常安全保证。

若 T 移动构造可能抛异常，优先用 std::swap 替代直接赋值：out.swap(data_.front())（前提是 T 支持 swap）
更稳妥的做法：只对 noexcept 类型启用移动；否则降级为拷贝，并静态断言 std::is_nothrow_copy_constructible_v<t></t>
try_push() 中若 push_back() 抛 std::bad_alloc，当前实现无法捕获——这是合理设计：内存不足是系统级失败，不应被“非阻塞”掩盖，而应由上层处理