c - 将结构体数组传递给线程

Question

我试图将结构的整个数组传递给线程，我需要它们的索引来区分线程内的不同数组。

typedef struct {
    int x;
    int y;
} StructA;

typedef struct {
    StructaA str;
    pthread_mutex_t* mutex;
} Parameters;

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int n=3;

main(){

    pthread_t thread;
    StructA str[n];
    Parameters thParam[n];

    for (int i=0; i<n; i++){
        thParam[i].str = &str[i];
        thParam[i].mutex = &mutex;
    }

    for (int i=0; i<n; i++){
        if(pthread_create(&thread[i], NULL, &Thread1, (void*)&thParam))
        exit;
    }

    etc...
}

Thread1(params*){

    Parameters * param[n];
    StructA stra[n];

    for (int i=0; i<n; i++){
        ??????????????????
    }
}

我曾经想过这样的事情:

for(int i=0; i<ghostN; i++){
    param[i] = ((Parameters*) params+i);
    stra[i] = param[i];
}

但我只是越来越乱了代码。执行此操作的正确方法是什么？

考虑到我必须这样做才能看到线程本身内部的每个 str[n] 值(我传递给线程的 main 内部的结构)。

Answer 1

主进程的内存在所有线程之间共享。因此，每个线程都有能力访问相同的变量或数组。传递给线程启动函数的唯一有意义的东西是一些独特的东西。注意，你不能传递任何东西对于线程来说，线程不是一个函数，但是你可以向线程启动函数传递一些东西，以将其保留在 this 的堆栈上功能。对函数的每次调用都会分配该函数独有的堆栈。

因此，在您的示例中，我会将 thParam 数组保留在全局范围内，以便所有线程都可以访问它，如下所示

Parameters thParam[n];
StructA str[n];

void *startThread(void *arg) {
     long int i = (long int)arg;

     use(thParam[i]);
}

main(){

    pthread_t thread[n];

    for (long int i=0; i<n; i++){
        thParam[i].str = &str[i];
        thParam[i].mutex = &mutex;
    }

    for (int i=0; i<n; i++){
        if(pthread_create(&thread[i], NULL, &startThread, (void*)i))
        exit;
    }
    ...
}

请注意，在上述情况下，所有对 thParam 的写入都是在线程启动之前完成的。所以不需要提供任何这里同步。此外，由于所有线程仅访问数组中自己的部分(由 i 定义)，因此无需同步其中之一。

您需要按值传递i，以避免同步问题。因此，您最好使用“long int”来将其大小与 void* 指针的大小相匹配。

在您的情况下，线程也必须是一个数组。