C++11 condition_variable条件变量的用法说明
作者:kingforyang 发布时间:2021-12-06 23:39:56
1 什么是条件变量
condition_variable是一个类,常和mutex搭配使用。
condition_variable类是一个同步原语,可用于阻塞一个线程或同时阻止多个线程,直到另一个线程修改共享变量并通知condition_variable。
防止多线程场景下,共享变量混乱。
理解条件变量要先理解三个概念:
锁 (锁住共享变量,线程独占)
wait
等待 (等待通知条件变量,变化的共享变量是否满足条件)notify
通知 (通知等待的条件变量,共享变量发送变化)
2 condition_variable类定义
2.1 wait函数
void wait( std::unique_lockstd::mutex& lock );
//Predicate是lambda表达式。
template< class Predicate >
void wait( std::unique_lockstd::mutex& lock, Predicate pred );
//以上二者都被notify_one())或notify_broadcast()唤醒,但是
//第二种方式是唤醒后也要满足Predicate的条件。
//如果不满足条件,继续解锁互斥量,然后让线程处于阻塞或等待状态。
//第二种等价于
while (!pred())
{
wait(lock);
}
3 condition_variable用法
condition_variable必定至少有两方,一方是资源修改线程,一方是资源等待线程。就跟打篮球一样,同时篮球只会在一个人手中,投篮后就释放了篮球所有权,其他方就会抢夺篮球所有权。
3.1 资源修改线程步骤
获取一个mutex使用 std::unique_lock< std::mutex >
保持锁定状态,修改共享变量
condition_variable对象执行notify_one或者notify_all(notify_one/notify_all执行前可以释放锁)
3.2 资源等待线程步骤
获取一个mutex使用 std::unique_lock< std::mutex > unlock用于保护要修改的共享变量
检查条件变量,
(1)条件变量满足,线程继续执行
(2)条件变量不满足,wait会释放unlock锁,并挂起线程。
当notify通知条件变量、超时过期或发生虚假唤醒时,线程被唤醒,互斥锁unlock被原子地重新获取。然后,线程应该检查条件,如果唤醒是假的,则继续等待
4 代码示例
4.1 无需notify场景
当wait第一次执行是,条件已经满足,则程序不会阻塞(即无需notify),会直接向下执行。(仅为说明3.2 中第2点(1)的情况)
#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <condition_variable>
using namespace std;
std::mutex m;
std::condition_variable cv;
std::string data;
bool ready = false;
bool processed = false;
void worker_thread()
{
std::cout << "3、worker_thread子线程开始执行" << endl;
// Wait until main() sends data
std::unique_lock<std::mutex> lk(m);
std::cout << "4、worker_thread子线程获取到锁,条件满足无需notify,不阻塞向下执行" << endl;
cv.wait(lk, []{return ready;});
// after the wait, we own the lock.
data += " after processing";
// Send data back to main()
processed = true;
std::cout << "5、Worker thread signals data processing completed\n";
// Manual unlocking is done before notifying, to avoid waking up
// the waiting thread only to block again (see notify_one for details)
lk.unlock();
std::cout << "6、worker_thread子线程交出执行权限,主线程执行" << endl;
std::this_thread::sleep_for(std::chrono::milliseconds(2000));
cv.notify_one();
std::cout << "9、worker_thread调用 notify_one" << endl;
}
int main()
{
std::thread worker(worker_thread);
std::cout << "1、主线程开始执行" << std::endl;
data = "Example data";
// send data to the worker thread
{
//std::this_thread::sleep_for(std::chrono::milliseconds(1000));
std::lock_guard<std::mutex> lk(m);
ready = true;
}
std::cout << "2、锁已经释放了,主线程休眠,子线程执行" << std::endl;
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
//cv.notify_one();
{
std::cout << "7、主线程data:" << data << endl;
std::unique_lock<std::mutex> lk(m);
std::cout << "8、主线程条件满足无需notify" << endl;
cv.wait(lk, []{return processed;});
}
worker.join();
std::cout << "10、主线程结束" << endl;
}
执行结果:
4.2 正常应用场景1
#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <condition_variable>
using namespace std;
std::mutex m;
std::condition_variable cv;
std::string data;
bool ready = false;
bool processed = false;
void worker_thread()
{
std::cout << "3、worker_thread子线程开始执行" << endl;
// Wait until main() sends data
std::unique_lock<std::mutex> lk(m);
std::cout << "4、worker_thread子线程获取到锁,条件不满足,释放lk锁,子线程阻塞" << endl;
cv.wait(lk, []{return ready;});
std::cout << "8、worker_thread子线程获取到锁,子线程继续执行" << endl;
// after the wait, we own the lock.
data += " after processing";
// Send data back to main()
processed = true;
std::cout << "9、Worker thread signals data processing completed\n";
// Manual unlocking is done before notifying, to avoid waking up
// the waiting thread only to block again (see notify_one for details)
lk.unlock();
std::this_thread::sleep_for(std::chrono::milliseconds(5000));
std::cout << "10、worker_thread调用 notify_one通知主线程执行" << endl;
cv.notify_one();
}
int main()
{
std::thread worker(worker_thread);
std::cout << "1、主线程开始执行" << std::endl;
data = "Example data";
// send data to the worker thread
{
std::cout << "2、主线程休眠,子线程进入执行" << std::endl;
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
std::cout << "5、主线程结束休眠,主线程获取lk锁,进入执行" << std::endl;
std::lock_guard<std::mutex> lk(m);
ready = true;
}
std::cout << "6、主线程释放lk,调用notify通知子线程" << std::endl;
cv.notify_one();
{
std::cout << "7、由于主线程的执行时钟周期未结束,继续执行主线程获取lk, wait检查条件不满足,释放锁" << endl;
std::unique_lock<std::mutex> lk(m);
cv.wait(lk, []{return processed;});
}
worker.join();
std::cout << "11、主线程结束" << endl;
}
执行结果:
这里notify执行后不一定立即执行子线程,如果cpu执行时钟周期未结束,则主线程会继续执行. 所以7,8,9,10顺序可能变化参见4.3
同时4.1也会因为cpu时钟周期,执行顺序有所变动。
4.3 正常应用场景2
#include <iostream>
#include <string>
#include <thread>
#include <mutex>
#include <condition_variable>
using namespace std;
std::mutex m;
std::condition_variable cv;
std::string data;
bool ready = false;
bool processed = false;
void worker_thread()
{
std::cout << "3、worker_thread子线程开始执行" << endl;
// Wait until main() sends data
std::unique_lock<std::mutex> lk(m);
std::cout << "4、worker_thread子线程获取到锁,条件不满足,释放lk锁,子线程阻塞" << endl;
cv.wait(lk, []{return ready;});
std::cout << "8、worker_thread子线程获取到锁,子线程继续执行" << endl;
// after the wait, we own the lock.
data += " after processing";
// Send data back to main()
processed = true;
std::cout << "9、Worker thread signals data processing completed\n";
// Manual unlocking is done before notifying, to avoid waking up
// the waiting thread only to block again (see notify_one for details)
lk.unlock();
std::cout << "10、worker_thread调用 notify_one通知主线程执行" << endl;
cv.notify_one();
}
int main()
{
std::thread worker(worker_thread);
std::cout << "1、主线程开始执行" << std::endl;
data = "Example data";
// send data to the worker thread
{
std::cout << "2、主线程休眠,子线程进入执行" << std::endl;
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
std::cout << "5、主线程结束休眠,主线程获取lk锁,进入执行" << std::endl;
std::lock_guard<std::mutex> lk(m);
ready = true;
}
std::cout << "6、主线程释放lk,调用notify通知子线程" << std::endl;
cv.notify_one();
{
for(int i = 0; i< 10000000; i++)
{
int j = i;
}
std::cout << "7、由于主线程的执行时钟周期未结束,继续执行主线程获取lk, wait检查条件不满足,释放锁" << endl;
std::unique_lock<std::mutex> lk(m);
cv.wait(lk, []{return processed;});
}
worker.join();
std::cout << "11、主线程结束" << endl;
}
执行结果:
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
来源:https://blog.csdn.net/kingforyang/article/details/121665393
猜你喜欢
- 这几年都在搞前后端分离、RESTful风格,我们项目中也在这样用。前几天有人遇到了解析JSON格式的请求数据的问题,然后说了一下解析的方式,
- Unity IPostprocessBuildWithReportUnity IPostprocessBuildWithReport是Uni
- 使用Eureka实现服务治理作用:实现服务治理(服务注册与发现)简介:Spring Cloud Eureka是Spring Cloud Ne
- 本文实例为大家分享了Java NIO实现多人聊天室的具体代码,供大家参考,具体内容如下1. 服务器端代码ChatServer类:packag
- 一、前言Redis是一个NoSQL(非关系型数据库)数据库之一,key-value存储系统或者说是一个缓存键值对数据库,具有如下特性:基于内
- 一. 思路今天接到个小任务,让把json文件转换成excel文件,按照列展开.思路:既然json已经都已经是现成的,那直接将jso
- 本文实例讲述了Java实现的RSA加密解密算法。分享给大家供大家参考,具体如下:import java.awt.AlphaComposite
- RecyclerView上拉加载,先看效果:网上有很多这类得框架,不过在自己的项目只用到上拉加载的功能,所以自己封装一个简单点的。主要依赖B
- 实现效果:先看下效果:需求是 滑动列表 ,其中一部分视图(粉丝数,关注数这一部分)在滑动到顶端的时候不消失,而是停留在整个界面头部。我们先分
- 不用单点登录,模拟远程项目的登录页面表单,在访问这个页面的时候自动提交表单到此项目的登录action,就可以实现登录到其他系统。ssh框架项
- 1、在java的构造方法中提供了 异常链.. 也就是我们可以通过构造方法不断的将 异常串联成一个异常链... 之所以需
- 1、通过C#调用Java的方法:在C#中添加调用的一些代码,利用Unity提供的一些接口实现调用Java!private const str
- Spring Boot项目默认的会打包成单一的jar文件,但是有时候我们并不想让配置文件、依赖包都跟可执行文件打包到一起。这时候可以在pom
- import java.io.File; public class ShowAllXML { public static void main
- 1.1 概述分布式系统:分布式系统指由很多台计算机组成的一个整体!这个整体一致对外,并且处理同一请求!系统对内透明,对外不透明!内部的每台计
- 本文实例为大家分享了java库存管理系统的具体代码,供大家参考,具体内容如下模拟真实的库存管理逻辑,完成超市管理系统的日常功能实现。经过分析
- Springboot添加server.servlet.context-pathserver.servlet.context-path配置的作
- 线程的两种创建方式及优劣比较1、通过实现Runnable接口线程创建(1).定义一个类实现Runnable接口,重写接口中的run()方法。
- 1.Open IDEA,choose "New-->Project"2.Choose "Spring I
- 归并排序简单解释:该算法是采用分治法,把数组不断分割,直至成为单个元素,然后比较再合并(合并的过程就是两部分分别从头开始比较,取出最小或最大