C++线程安全数组计数器：多线程处理vector时counter计数异常问题

核心错误点 #

• 锁的作用域完全错误：你在lambda函数内部定义了局部mutex lock变量，每个线程执行到这里都会创建属于自己的独立互斥锁，完全无法实现多线程间的互斥效果，多个线程会同时读写counter变量，导致计数混乱，还没遍历完全部元素就已经触发上限判断。
• 进程退出逻辑错误：触发上限时直接调用exit(0)会直接终止整个进程，即便还有线程正在处理已分配的任务，也会被强制中断，最终出现任务没跑完就停止的问题。

修复示例 #

第一步：调整锁的定义 #

把互斥锁定义为所有线程共享的外部变量，不要定义在lambda或者循环内部：

// 全局/类成员等所有线程可访问的位置定义
std::mutex g_counter_mtx;
int counter = 0;

第二步：修正线程内部逻辑 #

改用RAII锁避免手动管理锁的释放，同时把exit(0)改成退出当前线程的逻辑，且不要在锁内执行HTTP这类耗时操作避免降低并发效率：

for(int i=0; i<threads; i++){
    threadlist.push_back(thread([&]{
        while(true){
            int cur_idx = -1;
            // 用lock_guard自动管理锁的生命周期，异常场景也不会死锁
            std::lock_guard<std::mutex> lock(g_counter_mtx);
            if(counter >= Files::getUsers().size()){
                // 仅退出当前线程，不要终止整个进程
                return;
            }else {
                cur_idx = counter;
                counter++;
            }
            // 解锁后再执行HTTP请求逻辑，处理cur_idx对应的用户数据
        }
    }));
}
// 所有线程启动后记得join等待执行完成
for(auto& t : threadlist) {
    t.join();
}

可选优化 #

如果你想实现按100个元素批量分配减少锁竞争，可以改成批量取索引段的逻辑，进一步降低加锁频率，提升运行效率：

const int BATCH_SIZE = 100;
while(true) {
    int batch_start = -1;
    int batch_end = -1;
    std::lock_guard<std::mutex> lock(g_counter_mtx);
    if(counter >= Files::getUsers().size()) {
        return;
    }
    batch_start = counter;
    batch_end = std::min(counter + BATCH_SIZE, (int)Files::getUsers().size());
    counter = batch_end;
    // 解锁后批量处理batch_start到batch_end区间的元素
}

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