C语言多线程循环分组求和结果异常的问题解决

核心问题根源 #

你遇到的线程0结果不稳定、其余线程结果为0的问题，大概率是线程参数传递的竞态或内存非法访问导致的：

1. 若直接传递循环变量的地址（比如&j）给线程，所有线程会共享同一个内存地址的变量值。当循环快速执行完毕后，线程启动时读取到的j已经是循环结束后的H值，导致大部分线程计算范围完全错误，结果为0；而线程0可能因为启动稍快，偶尔能读取到正确的初始值，但也可能被循环变量的修改干扰，结果不稳定。
2. 若直接将int类型的j强制转换为void*传递（比如(void*)j），在64位系统下会存在数据截断风险（int是32位，void*是64位），导致线程读取到错误的ID；同时如果该值被当作指针使用（比如误转成int*），会访问非法内存，出现随机结果。

修正方案 #

1. 使用独立参数结构体传递线程信息

为每个线程分配独立的参数结构体，存储线程ID和结果存储地址，避免竞态和非法访问：

#include <pthread.h>
#include <stdlib.h>
#include <stdio.h>

#define H 4 // 线程数量
#define TOTAL_ITERATIONS 2000 // 总迭代次数（需是100*H的整数倍）

// 线程参数结构体：存储线程ID和结果指针
typedef struct {
    int thread_id;
    long long *result_sum;
} ThreadArgs;

void* _hilo(void *arg) {
    ThreadArgs *args = (ThreadArgs*)arg;
    int j = args->thread_id;
    long long *sum = args->result_sum;
    *sum = 0;

    // 按规则分配迭代组：第j个线程处理[j*100, j*100+99], [j*100+H*100, ...]
    for (long long batch_start = j * 100; batch_start < TOTAL_ITERATIONS; batch_start += H * 100) {
        // 连续100次求和迭代
        for (int k = 0; k < 100; k++) {
            *sum += (batch_start + k); // 替换为你的实际计算逻辑
        }
    }

    free(args); // 释放动态分配的参数内存
    pthread_exit(NULL);
}

int main() {
    pthread_t threads[H];
    long long thread_sums[H] = {0}; // 每个线程的独立结果变量

    // 创建线程
    for (int j = 0; j < H; j++) {
        ThreadArgs *args = malloc(sizeof(ThreadArgs));
        args->thread_id = j;
        args->result_sum = &thread_sums[j];
        pthread_create(&threads[j], NULL, _hilo, (void*)args);
    }

    // 等待所有线程完成并汇总结果
    long long parallel_sum = 0;
    for (int j = 0; j < H; j++) {
        pthread_join(threads[j], NULL);
        parallel_sum += thread_sums[j];
        printf("线程%d结果：%lld\n", j, thread_sums[j]);
    }

    // 串行计算对比
    long long serial_sum = 0;
    for (long long i = 0; i < TOTAL_ITERATIONS; i++) {
        serial_sum += i;
    }

    printf("\n串行计算结果：%lld\n", serial_sum);
    printf("并行计算结果：%lld\n", parallel_sum);
    printf("结果一致性：%s\n", serial_sum == parallel_sum ? "一致" : "不一致");

    return 0;
}

2. 关键修正点说明

• 独立参数分配：每个线程的参数通过malloc动态分配，确保线程启动后参数内存不会被销毁或覆盖。
• 结果变量隔离：用数组thread_sums存储每个线程的独立计算结果，完全避免数据竞争。
• 迭代范围正确性：按batch_start = j*100起始，每次步进H*100，严格符合你要求的循环分配规则。

3. 编译与运行

用以下命令编译（需链接pthread库）：

gcc -o thread_sum thread_sum.c -pthread
./thread_sum

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