std::condition_variable_any:: wait_until

wait_until hace que el hilo actual se bloquee hasta que se notifique la variable de condición, haya transcurrido la duración dada o ocurra un despertar espurio. pred se puede proporcionar opcionalmente para detectar despertar espurio.

Inmediatamente después de que wait_until retorne, lock está bloqueado por el hilo que realiza la llamada. Si esta postcondición no puede satisfacerse ^[1] , llama a std::terminate .

1. ↑ Esto puede ocurrir si el re-bloqueo del mutex lanza una excepción.

Parámetros

Valor de retorno

Excepciones

Notas

El estándar recomienda que se utilice el reloj vinculado a abs_time para medir el tiempo; no se requiere que ese reloj sea un reloj monótono. No hay garantías respecto al comportamiento de esta función si el reloj se ajusta de manera discontinua, pero las implementaciones existentes convierten abs_time de Clock a std::chrono::system_clock y delegan en POSIX pthread_cond_timedwait para que la espera respete los ajustes del reloj del sistema, pero no los del Clock proporcionado por el usuario. En cualquier caso, la función también puede esperar más allá de cuando se haya alcanzado abs_time debido a demoras de planificación o contención de recursos.

Incluso si el reloj en uso es std::chrono::steady_clock u otro reloj monótono, un ajuste del reloj del sistema puede inducir un despertar espurio.

Los efectos de notify_one() / notify_all() y cada una de las tres partes atómicas de wait() / wait_for() / wait_until() (desbloquear+esperar, despertar y bloquear) ocurren en un único orden total que puede verse como el orden de modificación de una variable atómica: el orden es específico de esta variable de condición individual. Esto hace imposible que notify_one() pueda, por ejemplo, retrasarse y desbloquear un hilo que comenzó a esperar justo después de que se realizara la llamada a notify_one() .

Ejemplo

#include <chrono>
#include <condition_variable>
#include <iostream>
#include <thread>
std::condition_variable_any cv;
std::mutex cv_m; // Este mutex se utiliza para tres propósitos:
                 // 1) sincronizar accesos a i
                 // 2) sincronizar accesos a std::cerr
                 // 3) para la variable de condición cv
int i = 0;
void waits()
{
    std::unique_lock<std::mutex> lk(cv_m);
    std::cerr << "Esperando... \n";
    cv.wait(lk, []{ return i == 1; });
    std::cerr << "...finalizada la espera. i == 1\n";
}
void signals()
{
    std::this_thread::sleep_for(std::chrono::seconds(1));
    {
        std::lock_guard<std::mutex> lk(cv_m);
        std::cerr << "Notificando...\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 << "Notificando de nuevo...\n";
    }
    cv.notify_all();
}
int main()
{
    std::thread t1(waits), t2(waits), t3(waits), t4(signals);
    t1.join(); 
    t2.join(); 
    t3.join();
    t4.join();
}

Esperando...
Esperando...
Esperando...
Notificando...
Notificando de nuevo...
...finalizada la espera. i == 1
...finalizada la espera. i == 1
...finalizada la espera. i == 1

Informes de defectos

Los siguientes informes de defectos que modifican el comportamiento se aplicaron retroactivamente a estándares publicados anteriormente de C++.

Véase también