4

我目前正在开发一个使用 pthreads 的项目。到目前为止，该项目启动用户指定数量的线程并在每个线程上执行一些工作，然后关闭。每个线程都存储在动态分配的内存数组中。我这样做使用：

threads = malloc(number_of_threads * sizeof(pthread_t));

然后我在 for 循环中创建每个线程：

pthread_create(&(threads[i]), NULL, client_pipe_run, (void *) &param[i]);

接下来我需要做的是存储这些线程的返回值。我的理解是我需要传递 pthread_join 一个我想要存储返回值的指针的地址。这是我有点困惑的地方。我对这一点的指针很好，然后我的大脑有点崩溃了哈哈。这是我关于如何实现这一点的想法，但我不相信这是正确的：

int *return_vals = malloc(sizeof(int) * number_of_threads);
for(i = 0; i< number_of_threads; i++)
{
pthread_join(&(threads[i]),(void *) &(return_vals[i]));
}

然后为了得到返回值，我会做类似的事情：

int val = *(return_val[0]);

对此的任何帮助将不胜感激！

4

1 回答 1

6

请注意，您正在为线程分配内存，如下所示：

threads = malloc(number_of_thread * sizeof(pthread_t));

但是对于返回值，您可以：

int *return_vals = malloc(sizeof(int *));

即这里也应该计算线程数：

int *return_vals = malloc(number_of_thread * sizeof(int));

然后您可以将返回值转换为void*：

void *foo(void *arg) {
    int i = 7;
    return (void*)i;
}

int main(void) {
    int i = 0;
    int thread_count = 3;
    pthread_t* threads = malloc(thread_count * sizeof(pthread_t));
    int *return_vals = malloc(thread_count * sizeof(int));

    // create threads:
    for(i = 0; i < thread_count; ++i)
        pthread_create(&threads[i], NULL, &foo, NULL);

    // wait untill they finish their work:
    for(i = 0; i < thread_count; ++i)
        pthread_join(threads[i], (void**) &return_vals[i]);

    // print results:
    for(i = 0; i < thread_count; ++i)
        printf("Thread %d returned: %d\n", i, return_vals[i]);

    // clean up:
    free(return_vals);
    free(threads);

    return 0;
}

或者您可以确保您的代码不会对您返回的类型的大小小于或等于做出任何假设，sizeof(void*)并在线程内为返回值动态分配内存：

void *foo(void *arg) {
    int* ret = malloc(sizeof(int));
    *ret = 7;
    return ret;
}

int main(void) {
    int i = 0;
    int thread_count = 3;
    pthread_t* threads = malloc(thread_count * sizeof(pthread_t));

    // array of pointers to return values of type int:
    int **return_vals = calloc(thread_count, sizeof(int*));

    // create threads:
    for(i = 0; i < thread_count; ++i)
        pthread_create(&threads[i], NULL, &foo, NULL);

    // wait untill they finish their work:
    for(i = 0; i < thread_count; ++i)
        pthread_join(threads[i], (void**) &return_vals[i]);

    // print results:
    for(i = 0; i < thread_count; ++i)
        printf("Thread %d returned: %d\n", i, *return_vals[i]);

    // clean up:
    for(i = 0; i < thread_count; ++i)
        free(return_vals[i]);
    free(return_vals);
    free(threads);

    return 0;
}

但是，如果您选择了后者，请注意最终可能导致的内存泄漏。

于 2013-03-04T19:13:47.007 回答