Попытка реализовать барьер для pthreads в C++ с использованием переменных условия pthread и мьютексов. ⇐ C++

[Anonymous]

В настоящее время я пытаюсь реализовать барьер для управления группой потоков. Классу барьера нужен конструктор, деструктор и метод ожидания, который, как мне кажется, я уже создал правильно. Функция потока предназначена для демонстрации того, что класс делает с потоками, печатая, какие потоки находятся за барьером, какой барьер, и печатая, что каждый поток прошел барьер. Когда я запускаю программу, она прекращает печать операторов после первого прохождения барьера и печатает только последний поток, достигший барьера. Вот код:

Код: Выделить всё

// barrier.cc
#include
#include 

class Barrier {
public:
explicit Barrier(int num_threads) : num_threads(num_threads), count(0), waiting(0) {
pthread_mutex_init(&mutex, nullptr);
pthread_cond_init(&cond, nullptr);
}

~Barrier() {
pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond);
}

void wait() {
pthread_mutex_lock(&mutex);

++waiting;
if (waiting == num_threads) {
waiting = 0; // Reset waiting count for the next barrier
pthread_cond_broadcast(&cond); // Unblock all threads
} else {
while (waiting < num_threads) {
pthread_cond_wait(&cond, &mutex);
}
}

pthread_mutex_unlock(&mutex);
}

private:
int num_threads;
int count;
int waiting;
pthread_mutex_t mutex;
pthread_cond_t cond;
};

// Example function to be run by threads
void* threadFunction(void* arg) {
Barrier* barrier = static_cast(arg);

for (int i = 0; i < 5; ++i) {
std::cout 

Подробнее здесь: [url]https://stackoverflow.com/questions/78679894/trying-to-implement-a-barrier-for-pthreads-in-c-using-pthread-condition-variab[/url]