void notify_all() 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_all();
}
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(); });
std::thread t3([&] { p.wait_for_data_to_process(); });
t1.join();
t2.join();
t3.join();
}
出力
process data
process data
バージョン
言語
- C++11
処理系
- Clang: ??
- GCC: 4.7.0 ✅
- ICC: ??
- Visual C++: 2012 ✅, 2013 ✅