使用带有 c++ openmp 的自旋锁

Question

我用唯一的锁和一个条件变量实现了这种方法。它将元素添加到数组中，但前提是数组未满。如果已满，它将等待其他线程取出一个元素，然后才将新元素放入。

void Filter::put(Person person)
{
std::unique_lock<std::mutex> guard(lock);
cv.wait(guard, [&] { return !full; });
container[count] = person;
count++;
empty = false;
if (count == 10)
full = true;
cv.notify_all();
}

我的目标是使用 OpenMP 编写相同的方法。如果我理解正确，#pragma omp critical (name)应该执行与唯一锁相同的操作。但是，我不确定我应该如何处理旋转锁。

Answer 1

好吧，如果有人感兴趣，这是我经过一些试验和错误后想出的解决方案，它似乎工作正常。

void Filter::put(Person person)
{
while (full || omp_test_lock(&spinlock) == 0)
{
}
container[count] = person;
count++;
empty = false;
if (count == 10)
full = true;
omp_unset_lock(&spinlock);
}