C++多线程处理购物车：收据混乱/截断问题排查求助

核心问题分析 #

你遇到的收据混乱/截断，本质不是商品扫描的锁有问题，而是收据输出或购物车数据拼接环节未保证线程安全：

• 虽然你在商品扫描（查询数据库）时加了锁，但多个线程可能同时对同一个输出目标（如文件、控制台）写入收据内容，导致不同购物车的文本交织。
• 如果购物车的收据内容是在共享内存中拼接，而非每个线程单独维护缓冲区，会出现数据覆盖。

常见错误点及修复方案 #

1. 输出流未加锁 #

多个线程直接调用cout、fwrite等写入收据时，即使商品查询线程安全，输出操作本身会被打断。

• 错误示例：

// 线程内处理完购物车后直接输出
cout << "购物车" << cartId << "收据:\n" << receiptContent << endl;

• 修复方案：给输出操作加单独的锁，确保每次完整写入一个购物车的收据：

std::mutex outputMutex;

// 处理完单个购物车后，锁定输出
std::lock_guard<std::mutex> lock(outputMutex);
cout << "购物车" << cartId << "收据:\n" << receiptContent << endl;

2. 购物车收据缓冲区共享 #

多个线程共用同一个字符串或缓冲区拼接收据，会导致不同购物车的数据互相覆盖。

• 错误示例：

// 全局或共享的收据缓冲区
std::string globalReceipt;

void processCart(Cart cart) {
    globalReceipt.clear();
    for (auto barcode : cart.barcodes) {
        std::lock_guard<std::mutex> dbLock(dbMutex);
        auto item = db.query(barcode);
        globalReceipt += item.name + " " + std::to_string(item.price) + "\n";
    }
    // 输出globalReceipt
}

• 修复方案：每个线程单独维护自己的收据缓冲区，避免共享：

void processCart(Cart cart) {
    // 线程局部缓冲区，每个线程独立
    std::string receipt;
    for (auto barcode : cart.barcodes) {
        std::lock_guard<std::mutex> dbLock(dbMutex);
        auto item = db.query(barcode);
        receipt += item.name + " " + std::to_string(item.price) + "\n";
    }
    // 锁定输出后写入
    std::lock_guard<std::mutex> outputLock(outputMutex);
    cout << "购物车" << cart.id << "收据:\n" << receipt << endl;
}

3. 锁的粒度或范围错误 #

如果锁没有正确包裹完整的商品查询逻辑，或误用了错误的锁对象，可能导致查询到错误的商品数据。

• 检查点：确保dbMutex是全局唯一的，且在每次查询数据库的整个过程中都持有锁，避免部分操作未被保护。

额外验证步骤 #

• 打印每个线程的ID和正在处理的购物车ID，确认是否有多个线程同时操作同一个购物车（如果购物车容器是共享的，需确保分配逻辑线程安全）。
• 临时切换为单线程运行，确认收据是否正常，排除数据库或购物车数据本身的问题。

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