std::atomic<T>:: wait

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

• Сравните представление значения выражения this - > load ( order ) с представлением значения old .
  • Если они равны, то блокируется до тех пор, пока * this не будет уведомлен с помощью notify_one() или notify_all() , или пока поток не будет разблокирован ложно.
  • В противном случае возвращает управление.

Эти функции гарантированно возвращают управление только при изменении значения, даже если базовая реализация разблокируется ложно.

Если order не является std:: memory_order_relaxed , std:: memory_order_consume , std:: memory_order_acquire или std:: memory_order_seq_cst , поведение не определено.

Параметры

Примечания

Эта форма обнаружения изменений часто более эффективна, чем простое опрашивание или чистые спинлоки.

Из-за проблемы ABA , временные изменения с old на другое значение и обратно на old могут быть пропущены и не разблокировать.

Сравнение производится побитово (аналогично std::memcmp ); операторы сравнения не используются. Биты заполнения, которые никогда не участвуют в представлении значения объекта, игнорируются.

Пример

#include <atomic>
#include <chrono>
#include <future>
#include <iostream>
#include <thread>
using namespace std::literals;
int main()
{
    std::atomic<bool> all_tasks_completed{false};
    std::atomic<unsigned> completion_count{};
    std::future<void> task_futures[16];
    std::atomic<unsigned> outstanding_task_count{16};
    // Создание нескольких задач, выполняющихся за разное
    // время, с последующим уменьшением счетчика оставшихся задач.
    for (std::future<void>& task_future : task_futures)
        task_future = std::async([&]
        {
            // Эта задержка имитирует выполнение реальной работы...
            std::this_thread::sleep_for(50ms);
            ++completion_count;
            --outstanding_task_count;
            // Когда счетчик задач достигает нуля, уведомить
            // ожидающую сторону (в данном случае - основной поток).
            if (outstanding_task_count.load() == 0)
            {
                all_tasks_completed = true;
                all_tasks_completed.notify_one();
            }
        });
    all_tasks_completed.wait(false);
    std::cout << "Tasks completed = " << completion_count.load() << '\n';
}

Tasks completed = 16

Смотрите также