C++的并发世界（九）——条件变量

0.绪论——单例模型

  单例设计模式是一种常见的设计模式，用于确保某个类只能创建一个实例。由于单例实例是全局唯一的。因此在多线程环境中使用单例模式时,需要考虑线程安全的问题。

1.消费者设计模式

2.condition_variable使用步骤

①准备好信号量

std::condition_variable cv;

②获取mutex
③获取mutex时修改数据
④释放锁并通知读取线程

lock.unlock();
cv.notify_one();
cv.notify_all();

3.读取共享变量的线程步骤

①获取与改变共享变量线程共同的mutex；
②等待信号通知 Wait()函数

4.condition_variable使用案例

#include <iostream>
#include <string>
#include <thread>
#include <list>
#include <sstream>
#include <mutex>

std::list<std::string> message;
std::mutex mux;
std::condition_variable cv;

void ThreadWrite()
{
	for (int i = 0;; i++)
	{
		std::stringstream ss;
		ss << "Write msg" << i;
		std::unique_lock<std::mutex> lock(mux);
		message.push_back(ss.str());
		lock.unlock();
		cv.notify_one();//发送信号
		std::this_thread::sleep_for(std::chrono::seconds(100));
	}
}

void ThreadRead(int i)
{
	for (;;)
	{
		std::cout << "read msg:" << " [in] " << i <<std::endl;
		std::unique_lock<std::mutex> lock(mux);
		cv.wait(lock);//阻塞扽得改信号
	
		while (!message.empty())
		{
			std::cout << i << "read:" << message.front() << std::endl;
			message.pop_front();
		}
	}
}

int main()
{ 
	std::thread th(ThreadWrite);
	th.detach();

	for (int i = 0; i < 3; i++)
	{
		std::thread th(ThreadRead,i + 1);
		th.detach();
	}

	getchar();
	return 0;
}