std::condition_variable_any::wait

This page has been machine-translated from the English version of the wiki using Google Translate. The translation may contain errors and awkward wording. Hover over text to see the original version. You can help to fix errors and improve the translation. For instructions click here. Click here for the English version of this page

wait blockiert den aktuellen Thread, bis die condition-Variable benachrichtigt wird oder ein spurious wakeup auftritt, optional wird eine Schleife durchlaufen, bis die Bedingung pred erfüllt ist.

1) lock wird atomar freigegeben, der aktuell ausführende Thread wird blockiert und zur Liste der Threads hinzugefügt, die auf *this warten. Der Thread wird freigegeben, wenn notify_all() oder notify_one() ausgeführt wird. Er kann auch fälschlicherweise entsperrt werden (spurious wakeup). Wenn der Thread freigegeben wird, unabhängig vom ​​Grund, wird lock zurückerworben und wait beendet. Wenn diese Funktion durch eine Ausnahme verlassen wird (exception), dann wird lock auch zurückerworben.

while (!pred()) {
  wait(lock);
}

Diese Überladung kann verwendet werden, um spurious wakeups zu behandeln, während auf das Eintreten der Bedingung pred gewartet wird.

[Bearbeiten] Parameter

[Bearbeiten] Rückgabewert

[Bearbeiten] Ausnahmen

[Bearbeiten] Notes

[Bearbeiten] Beispiel

#include <iostream>
#include <condition_variable>
#include <thread>
#include <chrono>
 
std::condition_variable_any cv;
std::mutex cv_m;
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::cerr << "Notifying...\n";
    cv.notify_all();
    std::this_thread::sleep_for(std::chrono::seconds(1));
    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

[Bearbeiten] Siehe auch