当前位置:网站首页 > 编程语言 > 正文

条件变量用法(条件变量的使用)

condition_variable是

C++

11中的一个同步原语,常和mutex搭配

使用

,用于阻塞一个线程或同时阻止多个线程,直到另一个线程修改共享变量并通知condition_variable。它可以防止多线程场景下,共享变量混乱。理解

条件变量

需要先理解三个概念:锁、wait等待和notify通知。

condition_variable的

使用

方法如下:

1.定义condition_variable对象和mutex对象

 c++ std::condition_variable cv; std::mutex cv_m; 

2.资源修改线程步骤

 c++ std::unique_lock<std::mutex> lk(cv_m); // 修改共享变量 cv.notify_one(); // 通知等待的线程 

3.资源等待线程步骤

 c++ std::unique_lock<std::mutex> lk(cv_m); cv.wait(lk, []{return true/false;}); // 等待 条件变量 

其中,wait函数会自动释放锁,等待

条件变量

被通知后重新获取锁。

4.代码示例

4.1 无需notify场景

 c++ #include <iostream> #include <thread> #include <mutex> #include <condition_variable>  std::mutex mtx; std::condition_variable cv; bool ready = false;  void print_id(int id) { std::unique_lock<std::mutex> lck(mtx); while (!ready) cv.wait(lck); std::cout << "thread " << id << ' '; }  void go() { std::unique_lock<std::mutex> lck(mtx); ready = true; cv.notify_all(); }  int main() { std::thread threads[10]; for (int i = 0; i < 10; ++i) threads[i] = std::thread(print_id, i);  std::cout << "10 threads ready to race... "; go();  for (auto& th : threads) th.join();  return 0; } 

4.2 正常应用场景1

 c++ #include <iostream> #include <thread> #include <mutex> #include <condition_variable>  std::mutex mtx; std::condition_variable cv; bool data_ready = false;  void consumer() { std::unique_lock<std::mutex> lck(mtx); cv.wait(lck, []{return data_ready;}); std::cout << "Consumer: data is ready "; }  void producer() { std::unique_lock<std::mutex> lck(mtx); data_ready = true; cv.notify_one(); }  int main() { std::thread t1(consumer); std::thread t2(producer);  t1.join(); t2.join();  return 0; } 

4.3 正常应用场景2

 c++ #include <iostream> #include <thread> #include <mutex> #include <condition_variable>  std::mutex mtx; std::condition_variable cv; bool data_ready = false;  void consumer() { std::unique_lock<std::mutex> lck(mtx); cv.wait(lck, []{return data_ready;}); std::cout << "Consumer: data is ready "; data_ready = false; }  void producer() { std::unique_lock<std::mutex> lck(mtx); data_ready = true; cv.notify_one(); }  int main() { std::thread t1(consumer); std::thread t2(producer);  t1.join(); t2.join();  return 0; } 
到此这篇条件变量用法(条件变量的使用)的文章就介绍到这了,更多相关内容请继续浏览下面的相关推荐文章,希望大家都能在编程的领域有一番成就!

版权声明


相关文章:

  • bt1120协议详解(bt1120协议详解 422)2024-12-16 09:36:07
  • 预训练模型是干嘛的(预训练模型对模型训练的影响)2024-12-16 09:36:07
  • ssh免密登录失败(ssh免密登录失败怎么办)2024-12-16 09:36:07
  • 跨域是什么,如何解决跨域(跨域是什么 怎么解决)2024-12-16 09:36:07
  • bt1120接口(bt1120转sdi芯片)2024-12-16 09:36:07
  • 学前儿童游戏的分类平行游戏(幼儿平行游戏的概念)2024-12-16 09:36:07
  • win10虚拟机安装win11(win10虚拟机安装win xp)2024-12-16 09:36:07
  • 左斜杠怎么打 电脑键盘符号(电脑左斜杠和右斜杠怎么打)2024-12-16 09:36:07
  • ad09如何设置捕捉点(ad怎么设置捕捉)2024-12-16 09:36:07
  • 网页聊天匿名怎么设置(网页聊天匿名怎么设置权限)2024-12-16 09:36:07
  • 全屏图片