std::condition_variable_any:: wait

wait は、条件変数が通知されるか、偽の起床が発生するまで、現在のスレッドをブロックします。 pred はオプションで提供され、偽の起床を検出するために使用できます。

wait が戻った直後に、 lock は呼び出しスレッドによってロックされます。この事後条件が満たせない場合 ^[1] 、 std::terminate を呼び出します。

1. ↑ ミューテックスの再ロック時に例外がスローされた場合に発生する可能性があります。

パラメータ

戻り値

例外

注記

オーバーロード (3) の戻り値は、 pred が true と評価されたかどうかを示し、停止要求の有無に関わらず適用されます。

notify_one() / notify_all() の効果と、 wait() / wait_for() / wait_until() の3つのアトミックな部分 （ロック解除＋待機、ウェイクアップ、ロック）は、 変更順序 として見なせる単一の全順序で発生します：この順序は個々の条件変数に固有です。これにより、例えば notify_one() が遅延して、 notify_one() の呼び出し直後に待機を開始したスレッドのブロックを解除する、といったことが不可能になります。

例

#include <chrono>
#include <condition_variable>
#include <iostream>
#include <thread>
std::condition_variable_any cv;
std::mutex cv_m; // このミューテックスは3つの目的で使用されます:
                 // 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++規格に対して遡及的に適用されました。

関連項目

外部リンク