std::condition_variable:: wait

wait блокирует текущий поток до тех пор, пока не будет получено уведомление от условной переменной или не произойдет ложное пробуждение. pred может быть опционально предоставлен для обнаружения ложных пробуждений.

Сразу после возврата из wait , lock. owns_lock ( ) имеет значение true , и lock. mutex ( ) заблокирован вызывающим потоком. Если эти постусловия не могут быть выполнены ^[1] , вызывается std::terminate .

Если выполняется любое из следующих условий, поведение не определено:

• lock. owns_lock ( ) равно false .
• lock. mutex ( ) не заблокирован вызывающим потоком.
• Если другие потоки также ожидают на * this , lock. mutex ( ) отличается от мьютекса, разблокированного функциями ожидания ( wait , wait_for и wait_until ), вызванными на * this этими потоками.

1. ↑ Это может произойти, если повторная блокировка мьютекса вызывает исключение.

Параметры

Исключения

Примечания

Эффекты notify_one() / notify_all() и каждой из трёх атомарных частей wait() / wait_for() / wait_until() (разблокировка+ожидание, пробуждение и блокировка) происходят в едином полном порядке, который можно рассматривать как порядок модификации атомарной переменной: этот порядок специфичен для данной конкретной переменной условия. Это делает невозможным, чтобы notify_one() , например, был задержан и разблокировал поток, который начал ожидание сразу после вызова notify_one() .

Пример

#include <chrono>
#include <condition_variable>
#include <iostream>
#include <thread>
std::condition_variable cv;
std::mutex cv_m; // Этот мьютекс используется для трёх целей:
                 // 1) для синхронизации доступа к i
                 // 2) для синхронизации доступа к std::cerr
                 // 3) для переменной условия cv
int i = 0;
void waits()
{
    std::unique_lock<std::mutex> lk(cv_m);
    std::cerr << "Waiting... \n";
    cv.wait(lk, []{ return i == 1; });
    std::cerr << "...finished waiting. i == 1\n";
}
void signals()
{
    std::this_thread::sleep_for(std::chrono::seconds(1));
    {
        std::lock_guard<std::mutex> lk(cv_m);
        std::cerr << "Notifying...\n";
    }
    cv.notify_all();
    std::this_thread::sleep_for(std::chrono::seconds(1));
    {
        std::lock_guard<std::mutex> lk(cv_m);
        i = 1;
        std::cerr << "Notifying again...\n";
    }
    cv.notify_all();
}
int main()
{
    std::thread t1(waits), t2(waits), t3(waits), t4(signals);
    t1.join(); 
    t2.join(); 
    t3.join();
    t4.join();
}

Waiting...
Waiting...
Waiting...
Notifying...
Notifying again...
...finished waiting. i == 1
...finished waiting. i == 1
...finished waiting. i == 1

Отчеты о дефектах

Следующие отчеты об изменениях поведения, влияющие на дефекты, были применены ретроактивно к ранее опубликованным стандартам C++.

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

Внешние ссылки