• Class / Function / Type

      std::
    • Header file

      <>
    • Other / All

    最終更新日時(UTC):
    が更新

    履歴 編集

    function
    <condition_variable>

    std::condition_variable_any::notify_all

    void notify_all() noexcept;
    

    概要

    待機している全てのスレッドを起床させる

    効果

    *thiscondition_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

    処理系

    参照