C++多线程for循环偶尔未终止引发数组越界异常求助

这个问题的核心原因几乎可以确定是线程创建时的循环变量竞态条件，具体来说是你在创建线程的lambda中错误地捕获了循环变量的引用，导致线程实际执行时读取到的是循环结束后的变量值。

具体细节拆解 #

1. 为什么会出现thr=8的情况？
   假设你的线程创建代码类似这样：

   int N_THREADS = std::thread::hardware_concurrency();
   std::vector<std::thread> threads;
   for (int thr = 0; thr < N_THREADS; ++thr) {
       // 错误：捕获了thr的引用
       threads.emplace_back([&]() {
           // 这里访问queryKPs_split.at(thr)
           std::cout << thr << " ";
       });
   }
   // 等待线程完成
   for (auto& t : threads) t.join();
   

   循环会快速完成所有线程的创建，但线程并不会立即启动执行。当线程真正开始运行时，循环变量thr已经完成了最后一次自增，变成了N_THREADS（也就是8）。那些启动较慢的线程就会读取到这个最终值，自然触发越界异常。

2. 日志输出的解释
   你看到的日志8 0 8 1 8 2 8 3 8 4 8 5 8 6 8 7 8，是因为部分线程启动足够快，在thr还没自增到下一个值时就读取了它（比如拿到0、1...7），而另一部分线程启动滞后，只能读到循环结束后的thr=8。最后那个单独的8，就是最后一个线程启动时读取到的循环终止值。

修复方案 #

解决这个问题的关键是让每个线程捕获到当前循环迭代的thr副本，而不是共享的引用：

方案1：捕获循环变量的值

直接在lambda中按值捕获thr，同时按需捕获其他需要的引用（比如queryKPs_split）：

for (int thr = 0; thr < N_THREADS; ++thr) {
    threads.emplace_back([thr, &queryKPs_split]() {
        // 现在thr是当前迭代的副本，不会被后续循环修改
        auto& split_data = queryKPs_split.at(thr);
        // 你的处理逻辑
    });
}

方案2：创建局部变量保存当前迭代值

如果需要捕获多个引用，可以先在循环内创建一个局部变量保存thr，再捕获这个局部变量：

for (int thr = 0; thr < N_THREADS; ++thr) {
    int current_thr = thr; // 每个循环迭代都有独立的current_thr副本
    threads.emplace_back([&, current_thr]() {
        auto& split_data = queryKPs_split.at(current_thr);
        // 你的处理逻辑
    });
}

这两种方式都能确保每个线程拿到的是对应迭代的thr值，不会出现越界的情况。

内容的提问来源于stack exchange，提问作者David W. Romero