C++ 多线程互斥锁(mutex,lock,lock_guard)

2020-02-14 17:24:35 浏览数 (2)

       对于互斥锁我们要先知道为什么要用互斥锁?它能解决什么问题?

       根据这两个问题,可以来举个例子说明一下,假如现在我们要求1-10000的和,然后我们为了提高效率,我们建立两个线程同时去计算[1,5000)的和以及[5000,10001)的和,那么用于计算和的变量都用相同的ans来获取结果,代码如下:

代码语言:javascript复制
#include <iostream>
#include <thread>

void work1(int& sum) {
	for (int i = 1; i < 5000; i  ) {
		sum  = i;
	}
}

void work2(int& sum) {
	for (int i = 5000; i <= 10000; i  ) {
		sum  = i;
	}
}

int fun() {
	int sum = 0;
	for (int i = 1; i <= 10000; i  ) {
		sum  = i;
	}
	return sum;
}

int main()
{
	int ans = 0;
	std::thread t1(work1, std::ref(ans));
	std::thread t2(work2, std::ref(ans));
	t1.join();
	t2.join();
	std::cout << "sum1 : " << ans << std::endl;
	std::cout << "sum2 : " << fun() << std::endl;
	return 0;
}

       为了区别多线程的计算结果,我用fun函数求的结果与其作比较,然后运行的结果如下图所示:

       我们发现两次的运算结果并不相同,那么我们可以分析一下原因,因为在计算过程中的sum是一个引用,是他们的共享资源,所以当一个线程正在计算 i的时候,此时还没有运算结束,就被切到了另一个线程中,然后在这个线程中可能会计算了很多次 i的操作,然后再切回那个线程中时,计算结果可能就会覆盖掉另一个线程的计算结果,因此这样求出来的数一定是比正确结果要小的,所以为了避免这种情况的发生,引入了互斥锁。

       互斥锁的重点在于他是一个锁,简单来说就是我们用锁将两个线程中计算过程分别用mutex锁上,那么当一个线程正在计算的时候,另一个线程就会等待这个计算的完成。大致流程是这样的,当work1准备计算sum =i的时候,用mutex将线程其锁上,如果此时sum =i还没有计算完就切到了work2的线程时,就会通过mutex检测到已经被锁上了,那么work2就会在此等待work1的计算完成,当work1的计算完成以后就会把锁解开,然后进行下一步的计算。所以两个线程种的计算过程都是加锁-计算-解锁的过程,这样就不会出现上述所说的那种情况了。

       互斥锁的实现过程很简单,mutex是一个类,首先我们要先创建出类对象std::mutex mylock,然后在你需要锁的代码块前后加上mylock.lock()和mylock.unlock(),就可以实现互斥锁的加锁和解锁了。可以具体实现可以看下面的代码:

代码语言:javascript复制
#include <iostream>
#include <thread>
#include <mutex>

void work1(int& sum, std::mutex& mylock) {
	for (int i = 1; i < 5000; i  ) {
		mylock.lock();
		sum  = i;
		mylock.unlock();
	}
}

void work2(int& sum, std::mutex& mylock) {
	for (int i = 5000; i <= 10000; i  ) {
		mylock.lock();
		sum  = i;
		mylock.unlock();
	}
}

int fun() {
	int sum = 0;
	for (int i = 1; i <= 10000; i  ) {
		sum  = i;
	}
	return sum;
}

int main()
{
	std::mutex mylock;
	int ans = 0;
	std::thread t1(work1, std::ref(ans), std::ref(mylock));
	std::thread t2(work2, std::ref(ans), std::ref(mylock));
	t1.join();
	t2.join();
	std::cout << "sum1 : " << ans << std::endl;
	std::cout << "sum2 : " << fun() << std::endl;
	return 0;
}

       这是第一种互斥锁的实现方法。还有一种是用lock_guard类模板,它的内部结构很简单,只有构造函数和析构函数,所以也很容里理解它的工作原理,在实例化对象时通过构造函数实现了lock,在析构函数中实现了unlock的操作。这样就可以避免忘记unlock的情况,具体的实现看下面的代码:

代码语言:javascript复制
#include <iostream>
#include <thread>
#include <mutex>

void work1(int& sum, std::mutex& mylock) {
	for (int i = 1; i < 5000; i  ) {
		std::lock_guard<std::mutex> mylock_guard(mylock);
		sum  = i;
	}
}

void work2(int& sum, std::mutex& mylock) {
	for (int i = 5000; i <= 10000; i  ) {
		std::lock_guard<std::mutex> mylock_guard(mylock);
		sum  = i;
	}
}

int fun() {
	int sum = 0;
	for (int i = 1; i <= 10000; i  ) {
		sum  = i;
	}
	return sum;
}

int main()
{
	std::mutex mylock;
	int ans = 0;
	std::thread t1(work1, std::ref(ans), std::ref(mylock));
	std::thread t2(work2, std::ref(ans), std::ref(mylock));
	t1.join();
	t2.join();
	std::cout << "sum1 : " << ans << std::endl;
	std::cout << "sum2 : " << fun() << std::endl;
	return 0;
}

       这样就在每次循环一次后会自动的构建互斥锁对象,循环完了就会析构掉这个互斥锁。当然为了使用的更灵活方便,我们可以通过大括号来规定实现的范围。比如下面这样:

代码语言:javascript复制
  {
 	std::lock_guard<std::mutex> mylockguard(mylock);
	/*...
	   中间用来写需要加锁的内容
	*/
  }

0 人点赞