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 または他の単調増加クロックであっても、システムクロックの調整によって偽のウェイクアップが発生する可能性があります。

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

関連項目