循环内使用std::thread导致参数与结果不匹配的问题求助

核心问题1：循环变量的引用传递导致数据不一致 #

你遇到的最关键问题是传递了循环变量ii的引用给子线程。主线程的循环会快速推进ii的值，而子线程的执行是异步的——当子线程真正开始读取ii时，主线程可能已经把ii更新到了下一个（甚至更后面的）值。比如第一个线程创建时ii=0，但主线程循环很快走到ii=1，子线程运行时读到的ii就变成了1，这就导致子线程里的索引和对应的emod/prat不匹配。

核心问题2：标准输出未同步导致输出乱序 #

多个线程同时调用cout时，虽然cout本身是线程安全的（不会出现内存崩溃），但它的输出操作可能被打断。比如一个线程刚输出了" In SubProgram "<<endl，另一个线程就插入了自己的输出，导致整体输出混乱。

修复后的代码示例 #

#include <iostream>
#include <cstdlib>
#include <thread>
#include <mutex>
#include <functional>

void subProg1(int ii, double& emod, double& prat, std::mutex& cout_mutex);
using namespace std;

int main() {
    const int imax = 4;
    double emod[4] = {10, 20, 30, 40};
    double prat[4] = {0.1, 0.2, 0.3, 0.4};
    std::thread threadpointer[imax];
    std::mutex cout_mutex; // 用于同步输出的互斥锁

    for (int ii = 0; ii < imax; ii++) {
        cout << "In main Program " << endl;
        cout << "count = : " << ii << " emod = : " << emod[ii] << " pRat = : " << prat[ii] << endl;
        // 1. 传递ii的值拷贝，而非引用
        // 2. 传递互斥锁的引用，用于子线程同步输出
        threadpointer[ii] = std::thread(subProg1, ii, ref(emod[ii]), ref(prat[ii]), ref(cout_mutex));
    }

    for (int ii = 0; ii < imax; ii++) {
        threadpointer[ii].join();
    }
}

void subProg1(int ii, double& emod, double& prat, std::mutex& cout_mutex) {
    // 用lock_guard自动管理互斥锁，确保输出完成后释放锁
    std::lock_guard<std::mutex> lock(cout_mutex);
    cout << "In SubProgram " << endl;
    cout << "count = : " << ii << " emod = : " << emod << " pRat = : " << prat << endl;
}

关键修改点说明 #

1. 循环变量传递方式修改：

   • 把subProg1的第一个参数从int& ii改成int ii，创建线程时直接传递ii的值（而非ref(ii)）。这样每个子线程都会拿到创建时ii的独立副本，不会被主线程的循环修改影响。

2. 添加输出同步：

   • 新增一个std::mutex，子线程输出前用std::lock_guard锁定，确保每次输出的完整内容是原子性的，不会被其他线程打断，避免输出乱序。

3. 代码细节优化：

   • 把ii的定义放到循环内部（for (int ii = 0;...)），避免变量作用域过大导致的潜在问题。
   • 用初始化列表直接初始化emod和prat，代码更简洁。

预期输出 #

修改后，子线程的输出会和主线程创建时的参数完全匹配，且输出顺序虽然可能和主线程交错，但每个子线程的内容是完整且正确的：

In main Program 
count = : 0 emod = : 10 pRat = : 0.1
In main Program 
count = : 1 emod = : 20 pRat = : 0.2
In SubProgram 
count = : 0 emod = : 10 pRat = : 0.1
In main Program 
count = : 2 emod = : 30 pRat = : 0.3
In SubProgram 
count = : 1 emod = : 20 pRat = : 0.2
In main Program 
count = : 3 emod = : 40 pRat = : 0.4
In SubProgram 
count = : 2 emod = : 30 pRat = : 0.3
In SubProgram 
count = : 3 emod = : 40 pRat = : 0.4

如果希望子线程的输出严格按顺序，你可以把join()放到循环内部（像你注释掉的那样），但这样就失去了并行的意义——主线程会等每个子线程执行完再创建下一个线程。

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