std::condition_variable_any:: wait_until

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

Сразу после того, как wait_until возвращает управление, lock блокируется вызывающим потоком. Если это постусловие не может быть выполнено ^[1] , вызывается std::terminate .

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_any 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++.

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