从文件读取和使用 pthread_create 时出现段错误

Question

每当我运行我的代码时，我都会经历 4 次迭代，读取文件并创建一个 pthread，直到它出现 ID 11 的段错误。

段错误是由我的打印 ln 引起的： printf("%s %s\n", "用包调用lab_manifes_alignment", *package); 但是为什么这会导致段错误呢？

停下来？

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

pthread_mutex_t mutex;

FILE *packageList;

void *submitPackage(void * packageReq){
    char ** package = packageReq;
    strcat(packageReq, " | sh lab_manifest_alignment.sh");
    printf("%s %s\n", "Calling lab_manifes_alignment with package", *package);
    system(packageReq);
    return NULL;
}


int main(){
    int numThreads;
    pthread_t threads[numThreads];

    //Init mutex
    if(pthread_mutex_init(&mutex, NULL)){
            fprintf(stderr, "Error initializing mutex");
    }

    int rc;
    FILE *packageList = fopen("package_list.txt", "r");
    if(packageList == NULL){
            fprintf(stderr, "ERROR: cannot open file.\n");
            return 1;
    }

    int i = 0;
    char line[128];

    while ( fgets ( line, sizeof line, packageList ) != NULL ){ 
    /* read a line spawn as many threads as needeed*/
        printf("%s %d, %s\n", "line: ",i, line);
        rc = pthread_create(&(threads[i]), NULL, submitPackage, line);

        if(rc){
            printf("ERROR: return code from pthread_create() is %d\n", rc);
            exit(EXIT_FAILURE);
        }
        i++;
    }

    numThreads = i;

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

    fclose(packageList);
    return 0;

}

Answer 1

我认为这里有问题：

char ** package = packageReq;

尝试改变：

char ** package = &packageReq;

Answer 2

pthread_t threads[numThreads];numThreads这里没有初始化，你应该选择线程的最大值或者动态分配。

fgets ( line, sizeof line, packageList ) 将 128 个字节读入line（数组的大小），但strcat(packageReq, " | sh lab_manifest_alignment.sh"); 在其后面添加了一些内容。这是您的段错误的原因。您应该增加数组的大小并减少fgets 中的大小参数。

您的主线程中的下一次迭代将覆盖您的 line 数组，而线程正在使用它。您应该使用二维数组或在每次迭代中分配一个缓冲区，并在使用它后在线程中释放它。每个线程都必须获得自己的缓冲区，而不是每个线程都一样。

char ** package = packageReq; 应该是char *package = packageReq; 并删除printf 处的*。