c - 如何在 C 中使用 pthreads 减少线程完成时的屏障计数

Question

我有一个函数:createrWorkerPool，它将产生“n”个工作线程，每个工作线程都将输入作为 pthread_create 的 args 中指定的文件，读取文件通过使用围绕它的互斥锁修改共享变量并等待屏障，直到所有线程都完成修改他们的共享变量。此操作在循环中发生很多次。

我面临的问题是，假设有两个文件 file1 和 file2，file2 的大小比 file1 大得多。屏障同步一直工作到 file1- 完成，但由于它完成执行，它不再到达屏障并且 file2 永远卡在屏障中。

我的问题是，有没有一种方法可以在线程退出时动态更改屏障正在等待的线程数。所以在上述情况下，如果 file1 提前完成，它会将屏障计数从 2 减少到 1，以便 file1 可以继续执行。我试着查看手册页，但没有看到任何功能。示例代码

pthread_mutex_t m1;
pthread_barrier_t b1;
//common function executed by each worker thread
void* doWork(void* arg) {
    const char* file = arg;
    while(1) {
        pthread_mutex_lock(&m1);
        // Modify shared variable
        pthread_mutex_unlock(&m1);
        // Wait for all threads to finish modifying shared variable
        pthread_barrier_wait(&b1);
        // Once all threads reach barrier check state of shared variable and do some task based on state
        // check for condition if true break out of loop

    }
    return 0;
}

所以基本上 thread1 操作 file1 之前完成并且 thread2 永远停留在障碍处

Answer 1

当屏障正在使用时，您无法真正更改屏障计数。

问题可能在于测试跳出循环的条件对于所有文件在同一时间并不成立 - 即，每个线程可能执行不同数量的循环。

如果是这种情况，一种解决方案是让每个提前完成的线程继续循环，但在每个循环中只在屏障上等待。然后安排所有线程一起退出 - 像这样:

void* doWork(void* arg)
{
    const char* file = arg;
    int work_done = 0;

    while(1) {
        if (work_done)
        {
            if (all_threads_done)
                break;

            pthread_barrier_wait(&b1);
            continue;
        }

        pthread_mutex_lock(&m1);
        // Modify shared variable
        pthread_mutex_unlock(&m1);
        // Wait for all threads to finish modifying shared variable
        pthread_barrier_wait(&b1);
        // Once all threads reach barrier check state of shared variable and do some task based on state
        if (finish_condition)
            work_done = 1;
    }
    return 0;
}