[编程基础] C++多线程入门5-使用互斥锁解决资源竞争
原始C++标准仅支持单线程编程。新的C++标准(称为C++11或C++0x)于2011年发布。在C++11中,引入了新的线程库。因此运行本文程序需要C++至少符合C++11标准。
5 使用互斥锁解决资源竞争
在本文中,我们将讨论如何使用互斥锁来保护多线程环境中的共享数据并避免资源竞争。为了解决多线程环境中的资源竞争,我们需要互斥锁,即每个线程都需要在修改或读取共享数据之前锁定互斥锁,并且在修改数据之后,每个线程都应解锁互斥锁。
5.1 std::mutex
在C++11线程库中,互斥锁位于mutex头文件中。表示互斥锁的类是std::mutex类
互斥锁有两种重要的方法:
- lock()
- unlock()
我们已经在上一篇文章中使用多线程钱包解释了资源竞争。在本文中,我们将看到如何使用std::mutex修复该多线程钱包中的资源竞争。由于电子钱包提供了在电子钱包中添加资金的服务,并且在不同线程之间使用了相同的电子钱包对象,因此我们需要在电子钱包的addMoney()方法中添加锁定,即在增加电子钱包的货币之前获取锁并在离开该钱包之前释放锁功能。让我们看一下代码:
内部维护货币并提供服务/功能的钱包类,即addMoney()。
该成员函数首先获取一个锁,然后将钱包对象的内部货币增加指定的数量,然后释放该锁。
#include<iostream>
#include<thread>
#include<vector>
#include<mutex>
class Wallet
{
int mMoney;
std::mutex mutex;
public:
Wallet() :mMoney(0) {}
int getMoney() { return mMoney; }
void addMoney(int money)
{
mutex.lock();
for (int i = 0; i < money; ++i)
{
mMoney++;
}
mutex.unlock();
}
};
现在,让我们创建5个线程,所有这些线程将共享Wallet类的同一对象,并使用其addMoney()成员函数并行向内部货币添加100000。因此,如果最初在钱包中的钱为0。那么在完成所有线程的执行后,在Wallet中的钱应该为500000。并且此互斥锁可确保电子钱包中的资金最终为500000。让我们测试一下:
#include<iostream>
#include<thread>
#include<vector>
#include<mutex>
class Wallet
{
int mMoney;
std::mutex mutex;
public:
Wallet() :mMoney(0) {}
int getMoney() { return mMoney; }
void addMoney(int money)
{
mutex.lock();
for (int i = 0; i < money; ++i)
{
mMoney++;
}
mutex.unlock();
}
};
int testMultithreadedWallet()
{
Wallet walletObject;
std::vector<std::thread> threads;
for (int i = 0; i < 5; ++i) {
threads.push_back(std::thread(&Wallet::addMoney, &walletObject, 100000));
}
for (int i = 0; i < threads.size(); i++)
{
threads.at(i).join();
}
return walletObject.getMoney();
}
int main()
{
int val = 0;
for (int k = 0; k < 10; k++)
{
if ((val = testMultithreadedWallet()) != 500000)
{
std::cout << "Error at count = " << k << " Money in Wallet = " << val << std::endl;
//break;
}
else
{
std::cout << "Now count = " << k << " Money in Wallet = " << val << std::endl;
//break;
}
}
return 0;
}
输出为:
Now count = 0 Money in Wallet = 500000
Now count = 1 Money in Wallet = 500000
Now count = 2 Money in Wallet = 500000
Now count = 3 Money in Wallet = 500000
Now count = 4 Money in Wallet = 500000
Now count = 5 Money in Wallet = 500000
Now count = 6 Money in Wallet = 500000
Now count = 7 Money in Wallet = 500000
Now count = 8 Money in Wallet = 500000
Now count = 9 Money in Wallet = 500000
可以保证不会发现钱包中的钱少于500000的单个情况。因为addMoney中的互斥锁可确保一旦一个线程完成了钱的修改,则只有其他任何线程才能修改Wallet中的钱。
但是,如果我们忘记在功能结束时解锁互斥锁,该怎么办?在这种情况下,一个线程将退出而不释放锁,而其他线程将保持等待状态。如果锁定互斥锁后发生某些异常,则可能发生这种情况。为了避免这种情况,我们应该使用std::lock_guard。
5.2 std::lock_guard
Lock_Guard是一个类模板,它实现了互斥锁的RAII。它将互斥体包装在其对象中,并将附加的互斥体锁定在其构造函数中。当调用它的析构函数时,它会释放互斥锁。让我们看看代码:
#include<iostream>
#include<thread>
#include<vector>
#include<mutex>
class Wallet
{
int mMoney;
std::mutex mutex;
public:
Wallet() :mMoney(0) {}
int getMoney() { return mMoney; }
void addMoney(int money)
{
// 在构造函数中,它锁定互斥锁 In constructor it locks the mutex
std::lock_guard<std::mutex> lockGuard(mutex);
for (int i = 0; i < money; ++i)
{
// If some exception occurs at this poin then destructor of lockGuard will be called due to stack unwinding.
// 如果在此位置发生异常,则由于堆栈展开,将调用lockGuard的析构函数。
mMoney++;
}
// Once function exits, then destructor of lockGuard Object will be called. In destructor it unlocks the mutex.
//一旦函数退出,则析构函数,将调用析构函数中的lockGuard对象,它解锁互斥锁。
}
};
int testMultithreadedWallet()
{
Wallet walletObject;
std::vector<std::thread> threads;
for (int i = 0; i < 5; ++i) {
threads.push_back(std::thread(&Wallet::addMoney, &walletObject, 100000));
}
for (int i = 0; i < threads.size(); i++)
{
threads.at(i).join();
}
return walletObject.getMoney();
}
int main()
{
int val = 0;
for (int k = 0; k < 10; k++)
{
if ((val = testMultithreadedWallet()) != 500000)
{
std::cout << "Error at count = " << k << " Money in Wallet = " << val << std::endl;
//break;
}
else
{
std::cout << "Now count = " << k << " Money in Wallet = " << val << std::endl;
//break;
}
}
return 0;
}
输出为:
Now count = 0 Money in Wallet = 500000
Now count = 1 Money in Wallet = 500000
Now count = 2 Money in Wallet = 500000
Now count = 3 Money in Wallet = 500000
Now count = 4 Money in Wallet = 500000
Now count = 5 Money in Wallet = 500000
Now count = 6 Money in Wallet = 500000
Now count = 7 Money in Wallet = 500000
Now count = 8 Money in Wallet = 500000
Now count = 9 Money in Wallet = 500000
5.3 参考
https://thispointer.com//c11-multithreading-part-5-using-mutex-to-fix-race-conditions/
相关文章
- 不要对折叠屏iPhone和iPad期待过早
- 为什么你的语音助手说话不像人?关于TTS技术原理及挑战
- 全面了解B端产品设计:基础扫盲篇
- 手机做到那几点才能完全取代PC?
- 外媒:若苹果想认真对待服务业务 iPhone就应降价
- 中国的移动互联网月活用户首次下降
- iOS 13 beta 5 发布 新功能与改变汇总
- SiriOS或将面世,助力苹果智能家居生态
- iPhone正式版系统更新,终于可以迁移数据了!
- 谷歌推Byteboard:以工作能力考核程序员面试者
- UI设计师如何正确的分析产品?来看这份全面的入门指南!
- 华为:安卓乃首选 鸿蒙用于物联网
- 华为董事长:安卓仍是首选 鸿蒙是否用于手机还未确定
- 微软专利:新一代Windows系统曝光,兼容安卓!
- 下一代 iPhone 设计的接班人,是「库克背后的库克」
- 鸿蒙OS内测系统体验曝光:界面与EMUI明显不同、简洁流畅
- 360小程序为“全场景”而生,打破PC、移动双端边界
- 手机操作系统曾经的春秋与战国
- 芯片为何成了“国人之痛“?专家详解背后原因
- 周鸿祎谈华为鸿蒙系统:可以打造成安卓一样的开源系统