C++多线程管道通信问题：子线程读取数组大小异常

核心问题：线程参数的生命周期失效 #

你代码里最致命的问题是线程参数的内存被提前销毁或覆盖：
在创建线程的循环中，child_arg是栈上的局部变量，每次循环迭代都会复用这块内存。当你调用pthread_create传入&child_arg时，线程启动后不一定能立刻读取参数，等线程真正执行时，child_arg所在的栈内存已经被循环后续步骤覆盖甚至销毁，导致子线程读取到的thread_arg结构体（包括管道文件描述符）是随机垃圾值，自然读不出正确的数组大小。

修复步骤 #

1. 传递正确的线程参数地址
   把线程参数存入thread_args后，传递vector中元素的地址给线程，而非局部变量的地址：

for (int i = 0; i < nprocesses; i++) {
    struct thread_arg child_arg;
    pipe(child_arg.parent_child);
    pipe(child_arg.child_parent);
    thread_args.push_back(child_arg);
    // 传递vector中刚插入的元素地址，避免局部变量内存失效
    s = pthread_create(&thr[i], NULL, childThreadFunction, (void *)&thread_args.back());
    if (s != 0) {
        fprintf(stderr, "Error creating the child thread");
    }
}

2. 添加IO操作的错误检查
   read和write调用可能失败或读写不完整，必须检查返回值，避免后续逻辑基于错误数据执行：

• 子线程读取部分：

int n;
ssize_t read_size = read(args->parent_child[0], &n, sizeof(int));
if (read_size != sizeof(int)) {
    fprintf(stderr, "Failed to read array size, got %zd bytes instead of %zu\n", read_size, sizeof(int));
    pthread_exit(NULL);
}
cout << "array size: " << n << endl;

• 主线程写入部分：

int n = splitVec.size();
ssize_t write_size = write(thread_args[i].parent_child[1], &n, sizeof(int));
if (write_size != sizeof(int)) {
    fprintf(stderr, "Failed to write array size for thread %d\n", i);
}

3. 清理无用的管道资源
   主线程开头创建的fd[2*nprocesses][2]管道数组在threads分支完全没用到，属于冗余代码，直接删除这部分管道创建逻辑，避免资源泄漏。

4. 替换非标准的变长数组
   C++不支持C风格的变长数组（long long arr[n];属于编译器扩展），改用std::vector更安全：

vector<long long> arr(splitVec.begin(), splitVec.end());
write(thread_args[i].parent_child[1], arr.data(), sizeof(long long)*n);

额外建议 #

• 子线程中记得关闭不需要的管道端，比如args->child_parent的读写端如果暂时不用，也应该关闭，避免资源泄漏。
• 主线程写完数据后关闭管道写端，这样子线程读取到EOF时可以正常结束，避免无限阻塞。

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