C++线程间的互斥和通信场景分析

 更新时间:2021年05月21日 10:31:41   作者:Redamanc  
很多朋友对C++线程间的互斥和通信知识掌握不是多牢靠,今天小编通过模拟车站卖票应用场景给大家详细解析C++线程间的互斥和通信知识,感兴趣的朋友跟随小编一起看看吧

互斥锁(mutex)

为了更好地理解,互斥锁,我们可以首先来看这么一个应用场景:模拟车站卖票。

模拟车站卖票

场景说明:
Yang车站售卖从亚特兰蒂斯到古巴比伦的时光飞船票;因为机会难得,所以票数有限,一经发售,谢绝补票。
飞船票总数:100张;
售卖窗口:3个。
对于珍贵的飞船票来说,这个资源是互斥的,比如第100张票,只能卖给一个人,不可能同时卖给两个人。3个窗口都有权限去售卖飞船票(唯一合法途径)。

不加锁的结果

根据场景说明,我们可以很快地分析如下:
可以使用三个线程来模拟三个独立的窗口同时进行卖票;
定义一个全局变量,每当一个窗口卖出一张票,就对这个变量进行减减操作。
故写出如下代码:

#include <iostream>
#include <thread>
#include <list>
using namespace std;

int tickets = 100; // 车站剩余票数总数

void sellTickets(int win)
{
	while (tickets > 0)
	{
		{
			if (tickets > 0)
			{
				cout << "窗口:" << win << " 卖出了第:" << tickets << "张票!" << endl;
				tickets--;
			}
			std::this_thread::sleep_for(std::chrono::microseconds(400));
		}
	}
}

int main()
{
	list<std::thread> tlist;
	for (int i = 1; i <= 3; ++i)
	{
		tlist.push_back(std::thread(sellTickets, i));
	}
	for (std::thread& t : tlist)
	{
		t.join();
	}
	cout << "所有窗口卖票结束!" << endl;

	return 0;
}

运行结果如下:

在这里插入图片描述

通过运行,我们可以发现问题:
对于一张票来说,卖出去了多次!
这不白嫖吗???这合适吗?
原因也很简单,对于线程来说,谁先执行,谁后执行,完全是根据CPU的调度,根本不可能掌握清楚。
所以,这个代码是线程不安全的!
那,怎么解决呢?
当然是:互斥锁了!

加锁后的结果

我们对上述代码做出如下修改:

#include <iostream>
#include <thread>
#include <list>
#include <mutex>
using namespace std;

int tickets = 100; 
std::mutex mtx;

void sellTickets(int win)
{
	while (tickets > 0)
	{
		{
			lock_guard<std::mutex> lock(mtx);
			if (tickets > 0)
			{
				cout << "窗口:" << win << " 卖出了第:" << tickets << "张票!" << endl;
				tickets--;
			}
			std::this_thread::sleep_for(std::chrono::microseconds(400));
		}
	}
}

int main()
{
	list<std::thread> tlist;
	for (int i = 1; i <= 3; ++i)
	{
		tlist.push_back(std::thread(sellTickets, i));
	}
	for (std::thread& t : tlist)
	{
		t.join();
	}
	cout << "所有窗口卖票结束!" << endl;

	return 0;
}

首先定义了一个全局的互斥锁std::mutex mtx;接着在对票数tickets进行减减操作时,定义了lock_guard,这个就相当于智能指针scoped_ptr一样,可以出了作用域自动释放锁资源。
运行结果如下:

在这里插入图片描述

我们可以看到这一次,就没问题了。

简单总结

互斥锁的使用可以有三种:
(首先都需要在全局定义互斥锁std::mutex mtx

  • 首先可以直接在需要加锁和解锁的地方,手动进行:加锁mtx.lock()、解锁mtx.unlock()
  • 可以在需要加锁的地方定义保护锁:lock_guard<std::mutex> lock(mtx),这个锁在定义的时候自动上锁,出了作用域自动解锁。(其实就是借助了智能指针的思想,定义对象出调用构造函数底层调用lock(),出了作用域调用析构函数底层调用unlock());
  • 可以在需要加锁的地方定义唯一锁:unique_lock<std::mutex> lock(mtx),这个锁和保护锁类似,但是比保护锁更加好用。(可以类比智能指针中的scoped_ptrunique_ptr的区别,二者都是将拷贝构造和赋值重载函数删除了,但是unique_ptrunique_lock都定义了带有右值引用的拷贝构造和赋值)

条件变量(conditon_variable)

如果说,互斥锁是为了解决线程间互斥的问题,那么,条件变量就是为了解决线程间通信的问题。
同样的,我们可以首先来看一个问题(模型):

生产者消费者线程模型

生产者消费者线程模型是一个很经典的线程模型;
首先会有两个线程,一个是生产者,一个是消费者,生产者只负责生产资源,消费者只负责消费资源。

产生问题

根据上述互斥锁的理解,我们可以写出如下代码:

#include <iostream>
#include <thread>
#include <mutex>
#include <queue>
using namespace std;

std::mutex mtx; 

class Queue
{
public:
	void put(int num)
	{
		lock_guard<std::mutex> lock(mtx);
		que.push(num);
		cout << "生产者,生产了:" << num << "号产品" << endl;
	}
	void get()
	{
		lock_guard<std::mutex> lock(mtx);
		int val = que.front();
		que.pop();
		cout << "消费者,消费了:" << val << "号产品" << endl;
	}
private:
	queue<int> que;
};

void producer(Queue* que)
{
	for (int i = 0; i < 10; ++i)
	{
		que->put(i);
		std::this_thread::sleep_for(std::chrono::milliseconds(200));
	}
}

void consumer(Queue* que)
{
	for (int i = 0; i < 10; ++i)
	{
		que->get();
		std::this_thread::sleep_for(std::chrono::milliseconds(200));
	}
}
int main()
{
	Queue que;

	std::thread t1(producer, &que);
	std::thread t2(consumer, &que);

	t1.join();
	t2.join();

	return 0;
}

同样的,我们定义了两个线程:t1t2分别作为生产者消费者,并且定义了两个线程函数producerconsumer,这两个函数接受一个Queue*的参数,并且通过这个指针调用putget方法,这两个方法就是往资源队列里面执行入队和出队操作。
运行结果如下:

在这里插入图片描述

我们会发现,出错了。
多运行几次试试:

在这里插入图片描述
在这里插入图片描述

我们发现,每次运行的结果还都不一样,但是都会出现系统崩溃的问题。
仔细来看这个错误原因:

在这里插入图片描述

我们再想想这个代码的逻辑:
一个生产者只负责生产;
一个消费者只负责消费;
他们共同在队列里面存取资源;
存取资源操作本身是互斥的。
发现问题了吗?
这两个线程之间彼此的操作独立,换句话说,
没有通信!
生产者生产的时候,消费者不知道;
消费者消费的时候,生产者也不知道;
但是消费者是要从队列里面取资源的,如果某一个时刻,队列里为空了,它就不能取了!

解决问题

分析完问题之后,我们知道了:
问题出在:没有通信上面。
那么如何解决通信问题呢?
当然就是:条件变量了!
我们做出如下代码的修改:

#include <iostream>
#include <thread>
#include <mutex>
#include <queue>
#include <condition_variable>
using namespace std;

std::mutex mtx; // 互斥锁,用于线程间互斥
std::condition_variable cv;// 条件变量,用于线程间通信

class Queue
{
public:
	void put(int num)
	{
		unique_lock<std::mutex> lck(mtx);
		while (!que.empty())
		{
			cv.wait(lck);
		}
		que.push(num);
		cv.notify_all();
		cout << "生产者,生产了:" << num << "号产品" << endl;
	}
	void get()
	{
		unique_lock<std::mutex> lck(mtx);
		while (que.empty())
		{
			cv.wait(lck);
		}
		int val = que.front();
		que.pop();
		cv.notify_all();
		cout << "消费者,消费了:" << val << "号产品" << endl;
	}
private:
	queue<int> que;
};

void producer(Queue* que)
{
	for (int i = 0; i < 10; ++i)
	{
		que->put(i);
		std::this_thread::sleep_for(std::chrono::milliseconds(200));
	}
}

void consumer(Queue* que)
{
	for (int i = 0; i < 10; ++i)
	{
		que->get();
		std::this_thread::sleep_for(std::chrono::milliseconds(200));
	}
}
int main()
{
	Queue que;

	std::thread t1(producer, &que);
	std::thread t2(consumer, &que);

	t1.join();
	t2.join();

	return 0;
}

这个时候我们再来看运行结果:

在这里插入图片描述

这个时候就是:
生产一个、消费一个。

原子类型(atomic)

我们前面遇到线程不安全的问题,主要是因为涉及++--操作的时候,有可能被其他的线程干扰,所以使用了互斥锁
只允许得到的线程进行操作;
其他没有得到的线程只能眼巴巴的干看着。
但是,对于互斥锁来说,它是比较重的,它对于临界区代码做的事情比较复杂。
简单来说,如果只是为了++--这样的简单操作互斥的话,使用互斥锁,就有点杀鸡用牛刀的意味了。
那么有没有比互斥锁更加轻量的,并且能够解决问题的呢?
当然有,就是我们要说的原子类型

简单使用

我们可以简单设置一个场景:
定义十个线程,对一个公有的变量myCount进行task的操作,该操作是对变量进行100次的++
所以,如果顺利,我们会最终得到myCount = 1000
代码如下:

#include <iostream>
#include <thread>
#include <atomic>
#include <list>

volatile std::atomic_bool isReady = false;
volatile std::atomic_int myCount = 0;

void task()
{
	while (!isReady)
	{
		// 线程让出当前的CPU时间片,等待下一次调度
		std::this_thread::yield();
	}

	for (int i = 0; i < 100; ++i)
	{
		myCount++;
	}
}

int main()
{
	std::list<std::thread> tlist;
	for (int i = 0; i < 10; ++i)
	{
		tlist.push_back(std::thread(task));
	}

	std::this_thread::sleep_for(std::chrono::milliseconds(200));
	isReady = true;

	for (std::thread& it : tlist)
	{
		it.join();
	}
	std::cout << "myCount:" << myCount << std::endl;

	return 0;
}

运行结果如下:

在这里插入图片描述

改良车站卖票

对于原子类型来说,使用方法非常简单:
首先包含头文件:#include <atomic>
接着把需要原子操作的变量定义为对应的原子类型就好:
bool -> atomic_bool;
int -> atomic_int;
其他同理。
理解了这个以后,我们可以使用原子类型对我们的车站卖票进行改良:

#include <iostream>
#include <thread>
#include <list>
#include <mutex>
#include <atomic>
using namespace std;

std::atomic_int tickets = 100; // 车站剩余票数总数

void sellTickets(int win)
{
	while (tickets > 0)
	{
		tickets--;
		cout << "窗口:" << win << " 卖出了第:" << tickets << "张票!" << endl;
	}
}

int main()
{
	list<std::thread> tlist;
	for (int i = 1; i <= 3; ++i)
	{
		tlist.push_back(std::thread(sellTickets, i));
	}
	for (std::thread& t : tlist)
	{
		t.join();
	}
	cout << "所有窗口卖票结束!" << endl;

	return 0;
}

可以看到,从代码长度来说就轻量了很多!
运行结果如下:

在这里插入图片描述

虽然还有部分打印乱序的情况:
(毕竟线程的执行顺序谁也摸不清 😦 )
但是,代码的逻辑没有问题!
不会出现一张票被卖了多次的情况!
这个原子类型也被叫做:无锁类型,像是一些无锁队列之类的实现,就是靠的这个东西。

以上就是C++线程间的互斥和通信的详细内容,更多关于C++线程间通信的资料请关注脚本之家其它相关文章!

相关文章

  • C及C++中typedef的简单使用介绍

    C及C++中typedef的简单使用介绍

    C/C++中关键字typedef的理解不是多透彻,今天小编抽空给大家分享下C及C++中typedef的简单使用介绍,需要的朋友可以参考下
    2016-10-10
  • 实现一个内存池管理的类方法

    实现一个内存池管理的类方法

    下面小编就为大家带来一篇实现一个内存池管理的类方法。小编觉得挺不错的现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-01-01
  • C++用mysql自带的头文件连接数据库

    C++用mysql自带的头文件连接数据库

    现在正做一个接口,通过不同的连接字符串操作不同的数据库。要用到mysql数据库。通过网上的一些资料和自己的摸索,大致清楚了C++连接mysql的方法。可以通过2种方法实现。第一种方法是利用ADO连接,第二种方法是利用mysql自己的api函数进行连接。今天主要来讲解下使用API
    2016-07-07
  • C++中atof 函数的介绍

    C++中atof 函数的介绍

    这篇文章主要给大家分享的是C++中atof 函数的介绍,在 stdlib.h 中 atof 函数,可用于将 char 字符串转为 float / double 浮点数类型,想具体了解语法的小伙伴可以参考下面文章的内容,希望对大家有所帮助
    2021-11-11
  • C++实现LeetCode(188.买卖股票的最佳时间之四)

    C++实现LeetCode(188.买卖股票的最佳时间之四)

    这篇文章主要介绍了C++实现LeetCode(188.买卖股票的最佳时间之四),本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • OpenCV利用高斯模糊实现简单的磨皮美颜效果

    OpenCV利用高斯模糊实现简单的磨皮美颜效果

    这篇文章主要介绍了通过OpenCV中的高斯模糊以及双边模糊来实现一个简单的磨皮美颜效果,文中的讲解很详细,感兴趣的同学可以学习一下
    2021-12-12
  • C语言 二级指针详解及示例代码

    C语言 二级指针详解及示例代码

    本文主要介绍C语言 二级指针,这里整理了C语言中二级指针的基础资料并附有示例代码和实现结果,帮助大家学习理解相关知识,有学习的朋友可以参考下
    2016-08-08
  • c病毒程序原理分析(防范病毒 c语言小病毒示例)

    c病毒程序原理分析(防范病毒 c语言小病毒示例)

    这篇文章主要介绍了病毒程序原理,写个小程序做演示,大家可以参考这个以防中相似C病毒
    2013-12-12
  • 基于C语言实现的贪吃蛇游戏完整实例代码

    基于C语言实现的贪吃蛇游戏完整实例代码

    这篇文章主要介绍了基于C语言实现的贪吃蛇游戏完整实例代码,对于学习游戏开发的朋友有一定的借鉴价值,需要的朋友可以参考下
    2014-08-08
  • visual studio 2015下boost库配置教程

    visual studio 2015下boost库配置教程

    这篇文章主要为大家详细介绍了visual studio 2015下boost库的配置教程,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-04-04

最新评论