c - 使用pthread和同步

我正在编写一个玩具程序，以帮助我理解障碍的工作原理。在程序中，我让每个线程进行检查以查看一个数组中的元素是否在另一个数组中。我能够让所有线程同时开始搜索，但是我想让它们在过滤之后全部聚在一起，以便正确地将任何数字添加到数组中。

否则，可能会将错误的数字添加到数组中。

编辑：有人建议我添加pthread_barrier_wait（＆after_filtering）;在调用filter_threads时，这似乎很有效。现在我知道我必须在main以及filter函数中添加一个等待调用，但是我不太了解执行的流程以及等待调用在main中的工作方式。我知道线程函数中的等待可确保所有线程在继续之前达到该点，但是那不是在创建线程后立即发生吗？意味着num的值应为99，而不是4、3、8、1？

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

pthread_barrier_t before_filtering, after_filtering;
int nums[4] = {99, 99, 99, 99};
int arr[15] = {12, 5, 31, 8, 1, 6, 24, 4, 81, 42};

void filter(int i, int a[]){
    // Loop through the list
    int j;
    for (j = 0; j < 10; j++)
    {
        if (nums[i] == a[j])
            nums[i] = 0;
    }
}

void *filter_threads(void *id){
    int *myid = (int *)id;
    printf("thread %d\n",*myid);
    pthread_barrier_wait(&before_filtering);
    filter(*myid, arr);
    pthread_barrier_wait(&after_filtering);
}

int main(void)
{
    pthread_t tids[3];
    int index[3];
    pthread_barrier_init(&before_filtering, NULL, 4);
    pthread_barrier_init(&after_filtering, NULL, 4);
    int i, j;

    for (i = 0; i < 3; i++)
    {
        index[i] = i + 1;
        pthread_create(&tids[i], NULL, filter_threads, &index[i]);
    }

    // Cannot call any filter function without first populating nums
    nums[0] = 4;
    nums[1] = 3;
    nums[2] = 8;
    nums[3] = 1;

    pthread_barrier_wait(&before_filtering);
    filter(0, arr);
    pthread_barrier_wait(&after_filtering);

    // Add new numbers to arr...

    printf("New nums: ");
    for (i = 0; i < 4; i++)
        printf("%d, ", nums[i]);
    printf("\n");

    for (i = 0; i < 3; i++)
        pthread_join(tids[i], NULL);

    // Print new arr...

    pthread_barrier_destroy(&before_filtering);
    pthread_barrier_destroy(&after_filtering);
}

我尝试在过滤后添加另一个等待调用，但是现在程序挂起了。我该怎么做？

最佳答案

屏障只是一种机制，可确保所有N个线程在继续操作之前到达代码中的特定点。因此，如果以4计数调用pthread_barrier_init，则在同一屏障上调用pthread_barrier_wait的任何线程将不会继续，直到另外三个线程也调用了pthread_barrier_wait。

因此，正如您的代码现在提供的那样：创建的三个线程将在启动后执行pthread_barrier_wait(&before_filtering)，直到主线程执行sleep(3)然后初始化nums数组之后，它们将全部阻塞。然后，主线程调用pthread_barrier_wait(&before_filtering)。这将释放主线程和所有其他线程以继续执行。

执行filter函数后，每个子线程和主线程都应执行pthread_barrier_wait(&after_filtering)。否则，主线程将停止，等待其他三个线程在屏障上等待。

话虽如此，根本没有必要使用第二道障碍。那时，主线程实际上只是在等待其他三个线程完成其任务并退出。由主线程完成的每个子线程上的pthread_join完成相同的操作：即线程上的pthread_join在该线程完成执行之前不会返回。

关于c - 使用pthread和同步，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/53365649/