目录
第一篇在这
上一章我们讲解了如何利用thread库初步进行多线程操作
这一章,我们主要讲的是锁(其实就是mutex锁)的概念

在上一章的多线程操作中我们也许会想到一个问题——如果变量或者资源他不是独占的,而是共享的(比如对于全局变量的修改),那么如果多个线程同时访问就会引起不可预料的错误
这个时候就必须要给线程进行加锁确保只能有一个线程运行此函数。
Mutex(互斥锁)是一种线程同步机制,用于保护共享资源的访问,防止多个线程同时访问和修改同一份数据而引发竞争条件(race condition)。
Mutex 的作用是在关键代码段前后加锁和解锁操作,确保只有一个线程能够进入临界区(critical section)执行代码,从而保证共享资源的安全访问。
同一时刻,同一临界区,只能有一个线程持有该锁
开头必然要声明库函数
#include
和其他类型的变量一样,之后锁还需要声明一个变量
mutex mtx_1;
这个最好是在全局变量中进行声明
在你写函数需要加锁时你只需要调用他们当中的lock(),以及unlck(),如果在执行lock时候如果锁已经被其他线程获取了,那么线程会进行等待
拿上面的进行举例就是
- mtx_1.lock();//加锁
- mtx_1.unlock();//解锁
运行一个
- #include
- #include
- #include
- #include
- #include
- using namespace std;
- mutex mtx_1;
- void F_1(int i) {
- mtx_1.lock();
- cout << "This is NO." << i << " project is runing." << endl;
- this_thread::sleep_for(chrono::seconds(i));
- cout << "This is NO." << i << " project is finishing." << endl;
- mtx_1.unlock();
- }
- int main() {
- clock_t now_time_1 = clock();
- cout << "This project is start!" << endl;//记录刚刚开始的时间
- vector
sum_1; - for (int i = 1; i <= 3; i++) {
- sum_1.push_back(thread(F_1, i));
- }
- for (int i = 0; i <= sum_1.size() - 1; i++) {
- sum_1[i].join();
- }
-
- cout << "This project is ready!" << endl;//记录结束的时间
- clock_t now_time_2 = clock();
- cout << "The cost time is " << now_time_2 - now_time_1 << " ms " << endl;
- return 0;
- }
简单的代码

可能有人就要问,这不和之前顺序执行的时间一样吗?
先不要急,这只是举一个例子,例子也比较极端开头就锁上了,事实上你只需要在有资源冲突的函数部分加锁即可,其他的地方依旧可以和以前一样,甚至不同的函数你可以命名两个锁分别进行执行加锁或者是解锁。
换言之,锁只是在你需要确保该资源变量在同一时刻只被一个线程访问时加上即可。
需要注意的是需要避免的是:两个或者多个线程之间所需要的资源被另外的线程锁住,从而造成死锁。
lock_guard是模板类,对比于mutex的区别是lock_guard在创建时会尝试获得锁的所有权(注意时尝试,如果获取不到就相当于没有用,并且不会报错),在作用域结束时会自动析构,无需手动解锁
该类不可中途上锁和解锁,不可复制
还是之前的代码
- #include
- #include
- #include
- #include
- #include
- using namespace std;
- mutex mtx_1;
- void F_1(int i) {
- lock_guard
guard_1(mtx_1); - cout << "This is NO." << i << " project is runing." << endl;
- this_thread::sleep_for(chrono::seconds(i));
- cout << "This is NO." << i << " project is finishing." << endl;
- }
- int main() {
- clock_t now_time_1 = clock();
- cout << "This project is start!" << endl;//记录刚刚开始的时间
- vector
sum_1; - for (int i = 1; i <= 3; i++) {
- sum_1.push_back(thread(F_1, i));
- }
- for (int i = 0; i <= sum_1.size() - 1; i++) {
- sum_1[i].join();
- }
-
- cout << "This project is ready!" << endl;//记录结束的时间
- clock_t now_time_2 = clock();
- cout << "The cost time is " << now_time_2 - now_time_1 << " ms " << endl;
- return 0;
- }

他并不需要解锁和解锁
adopt_lock用法为
lock_guardguard_1(mtx_1,adopt_lock);
加了这个参数,就可以在创建时候不上锁,代表表示这个互斥量已经lock();优化代码的运行时间,同时这个参数本质时起到一个标记
但是需要注意由于lock_guard不可以主动上锁,如果这个锁本身还没有lock过就会报错。
unique_lock的用法和lock_guard的用法类似,主要的区别在于他可以中途上锁以及解锁
对比于lock_guard会更加的灵活
但是所需要的内存空间会更大
同时它的也有adopt_lock参数用法一样,而且他还拥有其他的第二参数
他会尝试的去获取锁,如果锁没有被占用就会获取到,如果已经被占用了也会立即放回执行下面的代码不会进行堵塞,用法和adopt_lock一样
创建锁的时候不上锁(需要注意区分前面的adopt_lock()这个时没上锁的前提下(如果上锁了会报错)创建该锁时不上锁。之后再进行上锁。),用法也和adopt_lock一样
为释放unique_lock的所有权,注意是释放——release!!!!不是解锁——unlock,之后的锁需要你自己来管理
还是之前的代码中的函数
- void F_1(int i) {
- unique_lock
guard_1(mtx_1); - mutex* mtx_2 = guard_1.release();
- cout << "This is NO." << i << " project is runing." << endl;
- this_thread::sleep_for(chrono::seconds(i));
- cout << "This is NO." << i << " project is finishing." << endl;
- mtx_2->unlock();
- }

当然还是一样的
本章讲解了mutex大部分的知识点,使用时需要注意锁住的代码要尽可能的少而精准,这样程序的运行时间和稳定性以及安全性才可以同时得到显著的提升。