如何使用pthreads多线程执行二维数组处理的循环任务？

问题描述 #

我有一个需要处理的二维数组，当前程序为单线程设计，希望改用pthreads实现多线程设计（虽OpenMP更简便，但本次任务不允许使用）。以下是我的代码示例，在for循环中创建了4个线程。我需要在线程创建完成后执行一个for循环，请问如何用多线程运行该循环？是否需要创建并向pthread_create传递函数，还是可直接在后续放置该循环？

原代码：

void main() {

    int Array[10][15];

    int numThreads = 4;

    pthread_t threadId[numThreads];

    initArray(A,20); //Initializes the array and fills with some random data

    for(i = 0; i<numThreads; i++){

        pthread_create( &threadId[i], NULL); //Normally this would take an argument for some command I want to run concurrently, however, I want to run a for loop next concurrently using pthreads.

    }

}

核心结论 #

必须给pthread_create传递线程入口函数，不能直接在主线程放循环让多线程执行——pthreads的工作机制是每个线程必须绑定一个入口函数，线程启动后就会执行这个函数的逻辑。你需要把并行循环的逻辑拆分到这个函数中，通过参数给每个线程分配独立的任务区间。

完整实现示例 #

下面是修正后的代码，以按行拆分二维数组处理任务为例：

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

// 定义线程参数结构体：封装所有线程需要的信息
typedef struct {
    int (*array)[15];  // 二维数组指针
    int thread_id;     // 当前线程ID（0~numThreads-1）
    int num_threads;   // 总线程数
    int rows;          // 数组总行数
} ThreadData;

// 初始化数组的函数（示例实现）
void initArray(int array[10][15], int seed) {
    srand(seed);
    for (int i = 0; i < 10; i++) {
        for (int j = 0; j < 15; j++) {
            array[i][j] = rand() % 100;
        }
    }
}

// 线程入口函数：处理分配给自己的数组行
void* processArray(void* arg) {
    ThreadData* data = (ThreadData*)arg;
    int start_row = data->thread_id * (data->rows / data->num_threads);
    int end_row;

    // 最后一个线程处理剩余的行（避免总行数不能被线程数整除的情况）
    if (data->thread_id == data->num_threads - 1) {
        end_row = data->rows;
    } else {
        end_row = (data->thread_id + 1) * (data->rows / data->num_threads);
    }

    // 并行执行的循环逻辑：这里以打印每行数据为例，替换成你的实际处理逻辑
    for (int i = start_row; i < end_row; i++) {
        printf("线程%d处理行%d：", data->thread_id, i);
        for (int j = 0; j < 15; j++) {
            // 示例处理：可以修改数组值，比如data->array[i][j] *= 2;
            printf("%d ", data->array[i][j]);
        }
        printf("\n");
    }

    pthread_exit(NULL);  // 线程结束
}

int main() {
    int Array[10][15];
    int numThreads = 4;
    pthread_t threadId[numThreads];
    ThreadData threadData[numThreads];  // 每个线程的参数结构体

    // 初始化数组
    initArray(Array, 20);

    // 创建线程：给每个线程分配任务参数
    for (int i = 0; i < numThreads; i++) {
        threadData[i].array = Array;
        threadData[i].thread_id = i;
        threadData[i].num_threads = numThreads;
        threadData[i].rows = 10;

        // pthread_create的第三个参数是线程入口函数，第四个是传递给函数的参数
        if (pthread_create(&threadId[i], NULL, processArray, &threadData[i]) != 0) {
            perror("创建线程失败");
            exit(EXIT_FAILURE);
        }
    }

    // 主线程等待所有子线程完成
    for (int i = 0; i < numThreads; i++) {
        if (pthread_join(threadId[i], NULL) != 0) {
            perror("等待线程失败");
            exit(EXIT_FAILURE);
        }
    }

    return 0;
}

关键要点说明 #

• 线程入口函数是必须的：pthread_create的第三个参数是线程启动后执行的函数，签名必须是void* (*)(void*)，这是pthreads的强制要求，没有替代方案。
• 任务拆分逻辑：示例中按行拆分二维数组，每个线程处理连续的几行，这样能避免线程间的数据竞争（如果你的处理是只读或无冲突的写操作）。如果是需要共享数据的操作，还需要加互斥锁（pthread_mutex_t）保证同步。
• 参数传递：用结构体封装所有需要传递给线程的信息，因为pthread_create只能传递一个void*类型的参数。
• 等待线程结束：主线程必须调用pthread_join等待所有子线程完成，否则主线程可能提前退出，导致子线程被强制终止，无法完成任务。

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