C++实现简单的异步通知机制 _ condition_variable信号量【源码】-C++-PHP中文网

condition_variable不能单独用作信号量，因其无内部计数器，notify调用无人等待时会丢失，必须搭配mutex保护的显式状态变量并用while循环检查条件。

c++实现简单的异步通知机制 _ condition_variable信号量【源码】

为什么 condition_variable 不能单独用作信号量

std::condition_variable 本身不是信号量，它没有内部计数器，也不保存“唤醒次数”。只调用 notify_one() 或 notify_all() 而无人在 wait() 中阻塞时，通知会直接丢失。这和 sem_wait()/sem_post() 的行为本质不同——后者是可积累的。

常见错误现象：notify_one() 提前触发，后续线程调用 wait() 却永远卡住；或多个 notify_* 连续发，但只唤醒一个线程，其余通知被吞掉。

必须搭配一个显式的、线程安全的状态变量（如 bool ready 或 int count）使用
状态检查必须放在 while 循环里，不能用 if ——防止虚假唤醒
所有对共享状态的读写，必须在同一个 std::mutex 保护下完成

如何用 condition_variable 模拟二值信号量（0/1）

核心思路：用 bool signaled 表示是否已被触发，配合 std::mutex 和 std::condition_variable 构建“等待-通知”闭环。

class binary_semaphore {
    std::mutex mtx_;
    std::condition_variable cv_;
    bool signaled_ = false;

public:
    void notify() {
        std::lock_guard<:mutex> lk(mtx_);
        signaled_ = true;
        cv_.notify_one(); // 只需唤醒一个
    }

    void wait() {
        std::unique_lock<:mutex> lk(mtx_);
        cv_.wait(lk, [this] { return signaled_; }); // while 循环 + lambda 检查
        signaled_ = false; // 消费后重置
    }
};</:mutex></:mutex>

注意点：

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

wait() 返回时，signaled_ 一定为 true，但立刻被设回 false，保证“一次消费”语义
如果想支持超时等待，改用 cv_.wait_for(lk, dur, [...] {...})
不加锁直接读 signaled_ 是未定义行为；不加锁调用 notify() 也可能导致 wait() 永远错过信号

如何模拟计数信号量（支持多次 post / wait）

把 bool 换成 int 计数器即可，但要注意溢出和负值保护。

class counting_semaphore {
    std::mutex mtx_;
    std::condition_variable cv_;
    int count_ = 0;

public:
    explicit counting_semaphore(int initial = 0) : count_(initial) {}

    void signal() {
        std::lock_guard<:mutex> lk(mtx_);
        ++count_;
        cv_.notify_one();
    }

    void wait() {
        std::unique_lock<:mutex> lk(mtx_);
        cv_.wait(lk, [this] { return count_ > 0; });
        --count_;
    }
};</:mutex></:mutex>

关键差异：

signal() 不再清零 count_，而是递增；wait() 成功后才递减
初始值可以为负，但 wait() 会一直阻塞直到有足够 signal() 抵消
若需线程安全的 try_wait()，需用 cv_.wait_for(...) 配合 std::chrono::seconds(0)，并检查返回值

实际异步通知中容易漏掉的细节

真实场景下，比如主线程启动 worker 线程后等待其初始化完成，或 IO 完成后通知回调，光靠 condition_variable 还不够稳健。

worker 线程可能在 notify() 前崩溃，导致调用 wait() 的线程永久挂起 —— 必须配超时机制，例如 wait_for(lk, 5s) 并检查返回值
多个线程同时 wait()，但只有一个该被唤醒？用 notify_one()；全部都要响应？用 notify_all()，但注意性能开销
不要在析构函数里调用 wait()，也不要在持有锁期间做耗时操作（比如 IO、内存分配），否则阻塞其他线程
std::condition_variable 要求 wait() 的 std::unique_lock 必须关联同一 mutex；混用 std::shared_mutex 或其它锁类型会编译失败或 UB