c++11 多线程编程(三)------ 竞争和互斥锁
竞争条件
并发代码中最常见的错误之一就是竞争条件(race condition)。而其中最常见的就是数据竞争(data race),从整体上来看,所有线程之间共享数据的问题,都是修改数据导致的,如果所有的共享数据都是只读的,就不会发生问题。但是这是不可能的,大部分共享数据都是要被修改的。
而c++
中常见的cout
就是一个共享资源,如果在多个线程同时执行cout
,你会发发现很奇怪的问题:
#include <iostream>
#include <thread>
#include <string>
using namespace std;// 普通函数 无参
void function_1() {for(int i=0; i>-100; i--)cout << "From t1: " << i << endl;
}int main()
{std::thread t1(function_1);for(int i=0; i<100; i++)cout << "From main: " << i << endl;t1.join();return 0;
}
你有很大的几率发现打印会出现类似于From t1: From main: 64
这样奇怪的打印结果。cout
是基于流的,会先将你要打印的内容放入缓冲区,可能刚刚一个线程刚刚放入From t1:
,另一个线程就执行了,导致输出变乱。而c
语言中的printf
不会发生这个问题。
使用互斥元保护共享数据
解决办法就是要对cout
这个共享资源进行保护。在c++
中,可以使用互斥锁std::mutex
进行资源保护,头文件是#include <mutex>
,共有两种操作:锁定(lock)与解锁(unlock)。将cout
重新封装成一个线程安全的函数:
#include <iostream>
#include <thread>
#include <string>
#include <mutex>
using namespace std;std::mutex mu;
// 使用锁保护
void shared_print(string msg, int id) {mu.lock(); // 上锁cout << msg << id << endl;mu.unlock(); // 解锁
}void function_1() {for(int i=0; i>-100; i--)shared_print(string("From t1: "), i);
}int main()
{std::thread t1(function_1);for(int i=0; i<100; i++)shared_print(string("From main: "), i);t1.join();return 0;
}
修改完之后,运行可以发现打印没有问题了。但是还有一个隐藏着的问题,如果mu.lock()
和mu.unlock()
之间的语句发生了异常,会发生什么?unlock()
语句没有机会执行!导致导致mu
一直处于锁着的状态,其他使用shared_print()
函数的线程就会阻塞。
解决这个问题也很简单,使用c++
中常见的RAII
技术,即获取资源即初始化(Resource Acquisition Is Initialization)技术,这是c++
中管理资源的常用方式。简单的说就是在类的构造函数中创建资源,在析构函数中释放资源,因为就算发生了异常,c++
也能保证类的析构函数能够执行。我们不需要自己写个类包装mutex
,c++
库已经提供了std::lock_guard
类模板,使用方法如下:
void shared_print(string msg, int id) {//构造的时候帮忙上锁,析构的时候释放锁std::lock_guard<std::mutex> guard(mu);//mu.lock(); // 上锁cout << msg << id << endl;//mu.unlock(); // 解锁
}
可以实现自己的std::lock_guard
,类似这样:
class MutexLockGuard
{public:explicit MutexLockGuard(std::mutex& mutex): mutex_(mutex){mutex_.lock();}~MutexLockGuard(){mutex_.unlock();}private:std::mutex& mutex_;
};
为保护共享数据精心组织代码
上面的std::mutex
互斥元是个全局变量,他是为shared_print()
准备的,这个时候,我们最好将他们绑定在一起,比如说,可以封装成一个类。由于cout
是个全局共享的变量,没法完全封装,就算你封装了,外面还是能够使用cout
,并且不用通过锁。下面使用文件流举例:
#include <iostream>
#include <thread>
#include <string>
#include <mutex>
#include <fstream>
using namespace std;std::mutex mu;
class LogFile {std::mutex m_mutex;ofstream f;
public:LogFile() {f.open("log.txt");}~LogFile() {f.close();}void shared_print(string msg, int id) {std::lock_guard<std::mutex> guard(mu);f << msg << id << endl;}
};void function_1(LogFile& log) {for(int i=0; i>-100; i--)log.shared_print(string("From t1: "), i);
}int main()
{LogFile log;std::thread t1(function_1, std::ref(log));for(int i=0; i<100; i++)log.shared_print(string("From main: "), i);t1.join();return 0;
}
上面的LogFile
类封装了一个mutex
和一个ofstream
对象,然后shared_print
函数在mutex
的保护下,是线程安全的。使用的时候,先定义一个LogFile
的实例log
,主线程中直接使用,子线程中通过引用传递过去(也可以使用单例来实现),这样就能保证资源被互斥锁保护着,外面没办法使用但是使用资源。
但是这个时候还是得小心了!用互斥元保护数据并不只是像上面那样保护每个函数,就能够完全的保证线程安全,如果将资源的指针或者引用不小心传递出来了,所有的保护都白费了!要记住一下两点:
不要提供函数让用户获取资源。
std::mutex mu; class LogFile {std::mutex m_mutex;ofstream f; public:LogFile() {f.open("log.txt");}~LogFile() {f.close();}void shared_print(string msg, int id) {std::lock_guard<std::mutex> guard(mu);f << msg << id << endl;}// Never return f to the outside worldofstream& getStream() {return f; //never do this !!!} };
不要资源传递给用户的函数。
class LogFile {std::mutex m_mutex;ofstream f; public:LogFile() {f.open("log.txt");}~LogFile() {f.close();}void shared_print(string msg, int id) {std::lock_guard<std::mutex> guard(mu);f << msg << id << endl;}// Never return f to the outside worldofstream& getStream() {return f; //never do this !!!}// Never pass f as an argument to user provided functionvoid process(void fun(ostream&)) {fun(f);} };
以上两种做法都会将资源暴露给用户,造成不必要的安全隐患。
接口设计中也存在竞争条件
STL
中的stack
类是线程不安全的,于是你模仿着想写一个属于自己的线程安全的类Stack
。于是,你在push
和pop
等操作得时候,加了互斥锁保护数据。但是在多线程环境下使用使用你的Stack
类的时候,却仍然有可能是线程不安全的,why?
假设你的Stack
类的接口如下:
class Stack
{
public:Stack() {}void pop(); //弹出栈顶元素int& top(); //获取栈顶元素void push(int x);//将元素放入栈
private:vector<int> data; std::mutex _mu; //保护内部数据
};
类中的每一个函数都是线程安全的,但是组合起来却不是。加入栈中有9,3,8,6
共4个元素,你想使用两个线程分别取出栈中的元素进行处理,如下所示:
Thread A Thread B
int v = st.top(); // 6int v = st.top(); // 6
st.pop(); //弹出6st.pop(); //弹出8process(v);//处理6
process(v); //处理6
可以发现在这种执行顺序下, 栈顶元素被处理了两遍,而且多弹出了一个元素8
,导致`8没有被处理!这就是由于接口设计不当引起的竞争。解决办法就是将这两个接口合并为一个接口!就可以得到线程安全的栈。
class Stack
{
public:Stack() {}int& pop(); //弹出栈顶元素并返回void push(int x);//将元素放入栈
private:vector<int> data; std::mutex _mu; //保护内部数据
};//下面这样使用就不会发生问题
int v = st.pop(); // 6
process(v);
但是注意:这样修改之后是线程安全的,但是并不是异常安全的,这也是为什么STL
中栈的出栈操作分解成了两个步骤的原因。(为什么不是异常安全的还没想明白。。)
所以,为了保护共享数据,还得好好设计接口才行。
参考
- C++并发编程实战
- C++ Threading #3: Data Race and Mutex
c++11 多线程编程(三)------ 竞争和互斥锁相关推荐
- Linux与C++11多线程编程(学习笔记)
多线程编程与资源同步 在Windows下,主线程退出后,子线程也会被关闭; 在Linux下,主线程退出后,系统不会关闭子线程,这样就产生了僵尸进程 3.2.1创建线程 Linux 线程的创建 #inc ...
- 【C/C++多线程编程之六】pthread互斥量
多线程编程之线程同步互斥量 Pthread是 POSIX threads 的简称,是POSIX的线程标准. Pthread线程同步指多个线程协调地,有序地同步使用共享资源.[C/C++多线程编程之五] ...
- Linux多线程的同步-----信号量和互斥锁
前面两篇给基本概念讲过了,大家有兴趣的可以去看一下: Linux多线程_神厨小福贵!的博客-CSDN博客进程和线程的区别有哪些呢?进程是资源分配的最小单位,线程是CPU调度的最小单位进程有自己的独立地 ...
- c++11 多线程编程(六)------条件变量(Condition Variable)
互斥锁std::mutex是一种最常见的线程间同步的手段,但是在有些情况下不太高效. 假设想实现一个简单的消费者生产者模型,一个线程往队列中放入数据,一个线程往队列中取数据,取数据前需要判断一下队列中 ...
- Go并发编程之美(三)、互斥锁
go并发编程目录 一.前言 go语言类似Java JUC包也提供了一些列用于多线程之间进行同步的措施,比如低级的同步措施有 锁.CAS.原子变量操作类.相比Java来说go提供了独特的基于通道的同步措 ...
- c++11多线程编程同步——使用条件变量condition variable
简述 在多线程编程中,当多个线程之间需要进行某些同步机制时,如某个线程的执行需要另一个线程完成后才能进行,可以使用条件变量. c++11提供的 condition_variable 类是一个同步原语, ...
- 简单的多线程编程_同步与互斥问题
大纲: 零.关于同步与互斥的多线程编程(一般思路) 1. 申请"信号量"句柄,初始化信号量. (HANDLE ...) 2. 创建使用上线程的函数(函数中需要用到信号量).(Cre ...
- C++11多线程编程-两个进程轮流打印1~100
这是经典的同步互斥问题, 遵循原则: 1.条件变量需要锁的保护: 2.锁需要条件变量成立后,后重新上锁: 参考代码: //notify_one()(随机唤醒一个等待的线程) //notify_all( ...
- c++11 多线程编程(五)------unique_lock
互斥锁保证了线程间的同步,但是却将并行操作变成了串行操作,这对性能有很大的影响,所以我们要尽可能的减小锁定的区域,也就是使用细粒度锁. 这一点lock_guard做的不好,不够灵活,lock_guar ...
最新文章
- 2020年AI如何走?Jeff Dean和其他四位“大神”已做预测!
- 无人驾驶汽车系统入门:基于VoxelNet的激光雷达点云车辆检测及ROS实现
- 这7款APP到底有什么好,值得知乎2万人点赞,原来如此!
- hdu4965 巧用矩阵乘法结合律
- 【Android 内存优化】Java 引用类型 ( 强引用 | 软引用 | 弱引用 | 虚引用 )
- javascript 卸载事件(onunload)
- hadoop 集群:物理机突然间ping不同虚拟机
- Execute SQL Task 参数和变量的映射
- 从蚂蚁金服实践入手,带你深入了解 Service Mesh
- 北妈每日一题:如何甩锅给后端!
- jQuery jsonp跨域请求
- 使用jQuery Html() 作为客户端htmlEncode的问题
- popen和pclose
- Python 进阶之路
- 高等数学(下)思维导图
- IDEA删除多余空行
- Lodash的两种安装方式(npm安装/CDN)以及简单使用
- 二、8【FPGA】Verilog中锁存器(Latch)原理、危害及避免
- editormd显示后台html,yaboxxx. -yaboxxx.V0.8.82
- 【modlearts】华为人工智能平台_modelarts平台系列教程3_预置算法_图像识别1
热门文章
- C++ array vector 数组
- 设计模式-Builder Pattern
- C#读写文本文件,字符串截取
- Thinkpad SU使用方法FOR 2008
- Q115:Linux系统下CodeBlocks对PBRT-V3进行编译和调试
- 大数据的发展体现在哪些方面
- 华为否认鸿蒙为噱头网易,华为否认鸿蒙系统为噱头 必要可用于手机
- winform前后端框架_ABP开发框架前后端开发系列(1)框架的总体介绍
- 计算机操作员有关大学专业,如何根据自身特长选大学专业,这样操作最简单直接!...
- linux+swap分区规则_扩展Linux swap分区 两种方法