C++两个线程间变量同步的正确方法及互斥实现不同步问题排查

现有代码的同步逻辑存在以下几类问题，是偶发数值不一致的核心原因：

• 主线程的UpdateStoreStock函数中，UpdateNumProduct()、UpdateSalesPerMonth()执行在锁的作用域之外，如果这两个函数内部存在对productinStock、productinStore的读写操作，会直接触发未定义行为的数据竞争，这是偶发异常的最常见诱因。
• 要确认是否存在其他未贴出的代码路径，也会读写这两个共享变量但未加锁：只要有任意一处读写操作不在同一个mutex的保护范围内，都会出现数据竞争导致值不一致。
• 如果你提到的「秩（rank）」是MPI多进程场景下的进程标识，当前的线程级mutex完全无法实现跨进程的变量同步，进程间的共享内存同步需要用跨进程互斥量，更推荐直接用MPI消息通信来保证多门店的库存一致性，线程级mutex对其他进程的操作完全无约束。
• 现有代码中加锁后的额外大括号属于冗余写法，不会改变锁的释放时机（std::lock_guard会在当前函数栈帧销毁、guard对象析构时才释放锁），无功能影响但可简化。

线程场景修复代码 #

#include <mutex>

std::mutex mu;
int productinStock = 100;
int productinStore = 20;

// 运行在主线程：购买发生时调用
void UpdateStoreStock()
{
    std::lock_guard<std::mutex> guard(mu);
    // 所有访问共享变量的逻辑都必须放在锁的保护范围内
    UpdateNumProduct();
    UpdateSalesPerMonth();
    if(productinStore == 0 && 0 < productinStock)
        OrderProduct();
}

// 运行在子线程：接收其他门店调货
void RecvProduct(int num)
{
    std::lock_guard<std::mutex> guard(mu);
    productinStore = num;
    productinStock = productinStock - num;
}

优化建议 #

• 如果两个变量的读操作远多于写操作，可以替换为std::shared_mutex实现读写锁，写操作加独占锁、读操作加共享锁，提升并发性能。
• 如果是C++20及以上版本，单个变量的独立读写可以用std::atomic做原子封装，但如果两个变量的操作是需要保证原子性的组合操作（必须同时修改/同时读取），还是需要用互斥量保护，原子变量只能保证单个变量的读写原子性。
• 多进程（MPI rank）场景优先通过消息传递同步库存数据，不要用共享内存+互斥量的方案，避免跨进程同步的复杂问题。

内容的提问来源于stack exchange，提问作者Dan