std::condition_variable_any:: wait_for

wait_for は、条件変数が通知される、指定された期間が経過する、または偽のウェイクアップが発生するまで、現在のスレッドをブロックします。 pred はオプションで提供され、偽のウェイクアップを検出するために使用できます。

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

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

パラメータ

戻り値

例外

注記

ロック下で通知された場合でも、オーバーロード (1) は、タイムアウトによる復帰時の関連付けられた述語の状態について保証しません。

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++規格に対して遡及的に適用されました。

関連項目