如何使用pthreads库在C语言中为各线程分配独立文件读取？

核心思路 #

每个线程需要处理独立的文件，关键是给每个线程传递对应的文件名作为执行参数。利用pthread_create的第四个参数（void*类型），我们可以直接传入文件名指针，或是封装更多信息的结构体指针，确保线程能拿到专属的文件处理目标。

实现步骤与代码示例 #

以下是针对4个文件的完整可运行代码，逻辑清晰且易于扩展：

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

// 存储待读取的文件名列表
const char* filenames[] = {"file1.txt", "file2.txt", "file3.txt", "file4.txt"};
const int total_threads = 4;

// 线程执行函数：接收文件名并完成读取逻辑
void* read_file(void* arg) {
    const char* filename = (const char*)arg;
    FILE* fp = fopen(filename, "r");
    
    if (!fp) {
        perror("Failed to open file");
        pthread_exit(NULL);
    }

    printf("Thread %lu is processing %s:\n", pthread_self(), filename);
    char buffer[256];
    // 逐行读取文件内容，可根据需求替换为自定义处理逻辑
    while (fgets(buffer, sizeof(buffer), fp) != NULL) {
        printf("%s", buffer);
    }
    printf("\n");

    fclose(fp);
    pthread_exit(NULL);
}

int main() {
    pthread_t threads[total_threads];
    int i;

    // 循环创建线程，每个线程绑定一个文件名
    for (i = 0; i < total_threads; i++) {
        int ret = pthread_create(&threads[i], NULL, read_file, (void*)filenames[i]);
        if (ret != 0) {
            perror("Failed to create thread");
            exit(EXIT_FAILURE);
        }
    }

    // 等待所有线程执行完毕
    for (i = 0; i < total_threads; i++) {
        pthread_join(threads[i], NULL);
    }

    printf("All threads finished file reading.\n");
    return 0;
}

关键细节说明 #

1. 参数生命周期：示例中用全局数组存储文件名，确保线程运行时参数不会因栈内存销毁失效。如果使用栈上数组，需保证主线程在所有线程结束前不退出。
2. 线程等待：必须调用pthread_join让主线程等待子线程完成，避免主线程提前退出导致程序终止，子线程未完成任务。
3. 编译要求：编译时需要链接pthreads库，命令示例：gcc file_reader.c -o file_reader -pthread

扩展场景：传递更多参数 #

如果需要给线程传递除文件名外的其他数据（如处理规则、输出路径），可以定义结构体封装信息：

typedef struct {
    const char* filename;
    int output_flag;
    char output_path[64];
} ThreadTask;

创建线程时为每个结构体分配堆内存，线程函数执行完毕后释放内存即可。

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