void notify_one() noexcept;
概要
待機しているスレッドをひとつ起床させる
効果
*this
のcondition_variable_any
オブジェクトを待機しているスレッドがある場合、その一つをブロッキング解除する。
戻り値
なし
例外
投げない
例
#include <iostream>
#include <condition_variable>
#include <mutex>
#include <thread>
struct ProcessData {
std::recursive_mutex mtx_;
std::condition_variable_any cond_;
bool data_ready_ = false;
public:
// 処理に必要なデータの準備をする
void prepare_data_for_processing()
{
// ...準備処理...
{
std::lock_guard<std::recursive_mutex> lk(mtx_);
data_ready_ = true;
}
// 準備完了したので待機スレッドを起床させる
cond_.notify_one();
}
void wait_for_data_to_process()
{
std::unique_lock<std::recursive_mutex> lk(mtx_);
// データの準備ができるまで待機してから処理する
cond_.wait(lk, [this] { return data_ready_; });
process_data();
}
private:
void process_data()
{
// ...データを処理する...
std::cout << "process data" << std::endl;
}
};
int main()
{
ProcessData p;
std::thread t1([&] { p.prepare_data_for_processing(); });
std::thread t2([&] { p.wait_for_data_to_process(); });
t1.join();
t2.join();
}
出力
process data
バージョン
言語
- C++11
処理系
- Clang: ??
- GCC: 4.7.0 ✅
- ICC: ??
- Visual C++: 2012 ✅, 2013 ✅