std::condition_variable:: wait_until

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

Сразу после того, как wait_until возвращает управление, 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. ↑ Это может произойти, если повторная блокировка мьютекса вызывает исключение.

Параметры

Возвращаемое значение

Исключения

Примечания

Стандарт рекомендует использовать часы, связанные с abs_time для измерения времени; эти часы не обязаны быть монотонными. Не даётся никаких гарантий относительно поведения этой функции при дискретной корректировке часов, но существующие реализации преобразуют abs_time из Clock в std::chrono::system_clock и делегируют вызов POSIX-функции pthread_cond_timedwait , чтобы ожидание учитывало корректировки системных часов, но не пользовательских часов Clock . В любом случае, функция также может ожидать дольше, чем до момента достижения abs_time из-за задержек планирования или конкуренции за ресурсы.

Даже если используемые часы являются std::chrono::steady_clock или другим монотонным clock, корректировка системного clock может вызвать ложное пробуждение.

Эффекты 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++.

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