C++线程参数莫名自增问题求助

你遇到的核心问题是线程启动与循环变量更新的竞态条件：
在main的for循环里，你把循环变量i的地址&i传给了pthread_create，但i是一个会被循环持续修改的局部变量。线程启动需要一定时间，当新线程真正执行到int id = *reinterpret_cast<int*>(index);时，循环可能已经迭代了好几次，i的值早就不是创建线程时的那个值了。比如第一个线程刚要读取i时，循环已经走到了i=1，导致线程拿到的id变成1，而非预期的0，进而引发后续数组索引错误。

另外还有两个隐藏坑：

1. 全局变量clientHandlerThread每次创建线程都会被覆盖，你只能保存最后一个线程的ID，前面的线程ID全部丢失，根本无法管理这些线程。
2. 线程里用id-1作为connections的索引，当i=0时，id-1=-1，直接触发数组越界访问，这属于未定义行为，可能导致程序崩溃或诡异的运行结果。

方案1：直接传递数值（推荐，简单高效） #

在64位Linux系统中，void*的长度足够容纳一个int值，所以可以直接把i的数值转换成void*传递给线程，每个线程拿到的都是创建时i的独立副本，不会被循环修改影响：

修改pthread_create调用：

pthread_create(&clientHandlerThreads[i], NULL, ClientHandlerThread, (void*)i);

线程函数里转换回int：

int id = static_cast<int>(index);

方案2：为每个线程分配独立内存（适合复杂数据传递） #

如果需要传递更复杂的数据，可以用new为每个线程分配独立内存，在线程处理完后释放：

// main循环内
int* threadId = new int(i);
pthread_create(&clientHandlerThreads[i], NULL, ClientHandlerThread, threadId);

线程函数内：

int* idPtr = reinterpret_cast<int*>(index);
int id = *idPtr;
delete idPtr; // 用完及时释放内存

我还修复了线程ID存储、数组索引、系统调用错误处理等问题：

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <iostream>
#include <pthread.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <netinet/in.h>

const int MAX_CONNECTIONS = 100;
int connections[MAX_CONNECTIONS];
int connectionCounter = 0;
pthread_t clientHandlerThreads[MAX_CONNECTIONS]; // 用数组存储所有线程ID

void *ClientHandlerThread(void *index) {
    int id = static_cast<int>(index); // 直接转换数值，避免读取共享地址
    char buffer[256];
    ssize_t recvBytes;

    while(true) {
        // 处理recv返回值，判断客户端是否断开
        recvBytes = recv(connections[id], buffer, sizeof(buffer)-1, 0);
        if (recvBytes <= 0) {
            std::cout << "Client " << id << " disconnected." << std::endl;
            close(connections[id]);
            break;
        }
        buffer[recvBytes] = '\0'; // 确保字符串以空字符结尾

        // 转发消息给其他客户端
        for(int i = 0; i < connectionCounter; i++) {
            if(i == id) continue;
            ssize_t sendBytes = send(connections[i], buffer, recvBytes, 0);
            if (sendBytes <= 0) {
                std::cout << "Failed to send to client " << i << std::endl;
            }
        }
    }
    return NULL;
}

int main() {
    sockaddr_in addr;
    int addrlen = sizeof(addr);
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(1111);
    addr.sin_family = AF_INET;

    int sListen = socket(AF_INET, SOCK_STREAM, 0);
    if (sListen == -1) {
        perror("socket creation failed");
        exit(EXIT_FAILURE);
    }

    if (bind(sListen, (sockaddr*)&addr, addrlen) == -1) {
        perror("bind failed");
        close(sListen);
        exit(EXIT_FAILURE);
    }

    if (listen(sListen, SOMAXCONN) == -1) {
        perror("listen failed");
        close(sListen);
        exit(EXIT_FAILURE);
    }

    std::cout << "Server listening on 127.0.0.1:1111" << std::endl;

    int newConnection;
    for (int i = 0; i < MAX_CONNECTIONS; i++) {
        newConnection = accept(sListen, (sockaddr*)&addr, (socklen_t*)&addrlen);
        if (newConnection == -1) {
            perror("accept failed");
            continue;
        }

        char MOTD[256] = "Welcome! This is the Message of the Day.";
        send(newConnection, MOTD, sizeof(MOTD)-1, 0);

        connections[i] = newConnection;
        connectionCounter++;
        // 创建线程，传递i的数值而非地址
        if (pthread_create(&clientHandlerThreads[i], NULL, ClientHandlerThread, (void*)i) != 0) {
            perror("pthread_create failed");
            close(newConnection);
            connectionCounter--;
        }
        std::cout << "New client connected, ID: " << i << std::endl;
    }

    // 可选：等待所有线程结束（无限循环服务器可省略）
    for (int i = 0; i < connectionCounter; i++) {
        pthread_join(clientHandlerThreads[i], NULL);
    }

    close(sListen);
    return 0;
}

• 一定要处理recv、send、socket等系统调用的返回值，它们很容易因为权限、资源不足等原因失败，错误处理能帮你快速定位问题。
• 当客户端断开连接时，recv会返回0（正常断开）或-1（异常断开），此时要退出循环并关闭socket，避免无效的空循环。
• 数组索引必须保证合法，之前的id-1是错误逻辑，直接用i作为索引即可，因为connections[i]正好对应第i个连接。

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