如何通过pthread_create传递二维数组与int参数给线程函数？

你的代码存在几个核心问题，导致参数传递失败和运行结果异常：

核心问题 #

1. 线程函数签名不匹配：pthread_create要求线程函数必须是void* (*)(void*)类型，但你的shiftArray函数签名是void shiftArray(int mat[N][N], int k)，类型完全不兼容，会引发编译警告和运行时错误。
2. 多参数传递方式错误：pthread_create仅支持传递一个void*类型的参数，无法直接传递数组和k两个独立参数。
3. 全局变量引发竞态逻辑错误：用全局变量number控制线程处理的行范围，会导致两个线程执行逻辑混乱——第一个线程将number加2后处理0-1行，第二个线程再加2后处理0-3行，重复处理了所有行。
4. 全局变量依赖冗余：全局k虽然能被线程访问，但不利于代码模块化，且容易引发意外的变量修改。

解决方案 #

我们通过结构体封装多参数、修正线程函数签名、移除全局变量依赖这三个关键步骤来解决问题：

1. 定义参数结构体 #

创建一个结构体来打包线程需要的所有参数：二维数组、移位索引k、线程负责处理的起始行和结束行。

typedef struct {
    int (*mat)[N];  // 指向4×4二维数组的指针
    int k;          // 移位索引
    int start_row;  // 处理的起始行（包含）
    int end_row;    // 处理的结束行（不包含）
} ThreadData;

2. 修正线程函数 #

将线程函数改为符合pthread要求的签名，内部解析结构体参数，处理指定行的移位打印：

void* shiftArray(void* arg) {
    ThreadData* data = (ThreadData*)arg;
    int (*mat)[N] = data->mat;
    int k = data->k;
    int start = data->start_row;
    int end = data->end_row;

    // 加锁保证打印输出不混乱，若不需要严格行顺序可移除锁
    pthread_mutex_lock(&myMutex);
    for (int j = start; j < end; j++) {
        // 打印k索引后的元素
        for (int i = k; i < N; i++) {
            printf("%d ", mat[j][i]);
        }
        // 打印k索引前的元素
        for (int i = 0; i < k; i++) {
            printf("%d ", mat[j][i]);
        }
        printf("\n");
    }
    pthread_mutex_unlock(&myMutex);

    pthread_exit(NULL);
}

3. 重构主函数逻辑 #

在主函数中为每个线程分配独立的参数结构体，明确每个线程的处理范围，避免全局变量依赖：

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

#define NUMTHREADS 2
#define N 4
pthread_mutex_t myMutex;

typedef struct {
    int (*mat)[N];
    int k;
    int start_row;
    int end_row;
} ThreadData;

void* shiftArray(void* arg) {
    ThreadData* data = (ThreadData*)arg;
    int (*mat)[N] = data->mat;
    int k = data->k;
    int start = data->start_row;
    int end = data->end_row;

    pthread_mutex_lock(&myMutex);
    for (int j = start; j < end; j++) {
        for (int i = k; i < N; i++) {
            printf("%d ", mat[j][i]);
        }
        for (int i = 0; i < k; i++) {
            printf("%d ", mat[j][i]);
        }
        printf("\n");
    }
    pthread_mutex_unlock(&myMutex);

    pthread_exit(NULL);
}

int main(int argc, char *argv[]) {
    pthread_t threads[NUMTHREADS];
    ThreadData thread_data[NUMTHREADS];

    int k;
    printf("please enter k value: ");
    scanf("%d", &k);
    // 增加k的合法性判断
    if (k < 0 || k >= N) {
        printf("Error: k must be between 0 and %d\n", N-1);
        return 1;
    }
    printf("k = %d\n", k);

    int mat[N][N] = {
        {1, 2, 3, 4},
        {5, 6, 7, 8},
        {9, 10, 11, 12},
        {13, 14, 15, 16}
    };

    pthread_mutex_init(&myMutex, NULL);

    // 配置第一个线程：处理0、1行
    thread_data[0].mat = mat;
    thread_data[0].k = k;
    thread_data[0].start_row = 0;
    thread_data[0].end_row = 2;

    // 配置第二个线程：处理2、3行
    thread_data[1].mat = mat;
    thread_data[1].k = k;
    thread_data[1].start_row = 2;
    thread_data[1].end_row = 4;

    for (int i = 0; i < NUMTHREADS; i++) {
        pthread_create(&threads[i], NULL, shiftArray, &thread_data[i]);
    }

    for (int i = 0; i < NUMTHREADS; i++) {
        pthread_join(threads[i], NULL);
    }

    pthread_mutex_destroy(&myMutex);

    return 0;
}

关键改进点说明 #

• 每个线程处理独立的行范围，避免了原代码中全局变量导致的重复处理问题。
• 结构体封装参数，完美解决了pthread只能传递单个参数的限制。
• 线程函数签名完全符合pthread规范，消除了编译和运行时的类型错误。
• 增加了k值的合法性检查，避免非法输入导致的移位逻辑错误。
• 锁仅用于保护打印输出，避免多线程同时打印导致的内容混乱，逻辑更清晰。

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