C++詳解如何實(shí)現(xiàn)兩個(gè)線(xiàn)程交替打印

更新時(shí)間：2022年08月26日 10:08:01 作者：小小酥誒

這篇文章主要介紹了使用C++庫(kù)實(shí)現(xiàn)兩個(gè)線(xiàn)程交替打印，一個(gè)線(xiàn)程打印奇數(shù)、一個(gè)線(xiàn)程打印偶數(shù)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

C++線(xiàn)程庫(kù)，點(diǎn)擊此處查看文檔

首先簡(jiǎn)單搭一個(gè)框架，讓兩個(gè)線(xiàn)程先嘗試實(shí)現(xiàn)交替打印。

//實(shí)現(xiàn)兩個(gè)線(xiàn)程交替打印
#include <iostream>
#include <thread>
using namespace std;
int main(void)
{
	int n = 100;
	int i = 0;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i](){
		while (i < n)
		{
			cout << i << " ";
			i++;
		}
	});
	thread t2([&n, &i]() {
		while (i < n)
		{
			cout << i << " ";
			i++;
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

為了讓我們更加清楚是哪個(gè)線(xiàn)程打印了，我們需要獲取線(xiàn)程的ID。

#include <iostream>
#include <thread>
using namespace std;
int main(void)
{
	int n = 100;
	int i = 0;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i](){
		while (i < n)
		{
			cout << this_thread::get_id()  << ": " << i << endl;
			i++;
		}
	});
	thread t2([&n, &i]() {
		while (i < n)
		{
			cout << this_thread::get_id() << ": " << i << endl;
			i++;
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

這顯然沒(méi)有完成兩個(gè)線(xiàn)程交替打印的目的，甚至數(shù)據(jù)的打印都非常地亂。這是因?yàn)閕是臨界資源，多個(gè)線(xiàn)程爭(zhēng)搶訪(fǎng)問(wèn)臨界資源可能會(huì)造成數(shù)據(jù)二義，線(xiàn)程是不安全的，需要保證任意時(shí)刻只有一個(gè)線(xiàn)程能夠訪(fǎng)問(wèn)臨界資源。

所以創(chuàng)建一個(gè)互斥量，并在臨界區(qū)合適的地方加鎖和解鎖。由于線(xiàn)程的執(zhí)行函數(shù)我使用了lambda表達(dá)式，為了讓兩個(gè)線(xiàn)程使用的是同一把鎖，把鎖創(chuàng)建在了main函數(shù)內(nèi)，并在lambda表達(dá)式內(nèi)使用了引用捕捉。

#include <iostream>
#include <thread>
#include <mutex>
using namespace std;
int main(void)
{
	int n = 100;
	int i = 0;
	mutex mtx;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i, &mtx](){
		while (i < n)
		{
			mtx.lock();
			cout << this_thread::get_id()  << ": " << i << endl;
			i++;
			mtx.unlock();
		}
	});
	thread t2([&n, &i, &mtx]() {
		while (i < n)
		{
			mtx.lock();
			cout << this_thread::get_id() << ": " << i << endl;
			i++;
			mtx.unlock();
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

在C++中，一般不直接操作鎖，而是由類(lèi)去管理鎖。

//第一個(gè)管理鎖的類(lèi)
template <class Mutex> class lock_guard;
//第二個(gè)管理鎖的類(lèi)
template <class Mutex> class unique_lock;

lock_guar類(lèi)，只有構(gòu)造和析構(gòu)函數(shù)。一般用于加鎖和解鎖，這里進(jìn)行簡(jiǎn)單的模擬：

//注意：為了使得加鎖和解鎖的是同一把鎖
//需要使用引用
template <class Lock>
class LockGuard
{
public:
	LockGuard(Lock &lck)
		:_lock(lck)
	{
		_lock.lock();
	}
	~LockGuard()
	{
		_lock.unlock();
	}
private:
	Lock &_lock;
};

unique_lock的成員方法就不僅僅是析構(gòu)函數(shù)和構(gòu)造函數(shù)。詳見(jiàn)文檔unique_lock介紹和使用。

這里將鎖交給unique_lock類(lèi)的對(duì)象進(jìn)行管理。

int main(void)
{
	int n = 100;
	int i = 0;
	mutex mtx;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i, &mtx, &cv, &flag](){
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			cout << this_thread::get_id()  << ": " << i << endl;
			i++;
		}
	});
	thread t2([&n, &i, &mtx, &cv, &flag]() {
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			cout << this_thread::get_id() << ": " << i << endl;
			i++;
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

線(xiàn)程是安全了，但如果其中一個(gè)線(xiàn)程競(jìng)爭(zhēng)鎖的能力比較強(qiáng)，那么可能會(huì)出現(xiàn)上面這種情況。

需要控制：一個(gè)線(xiàn)程執(zhí)行一次后，如果再次去執(zhí)行就不準(zhǔn)許了，同時(shí)可以喚醒另一個(gè)進(jìn)程去執(zhí)行，如此循環(huán)往復(fù)達(dá)到交替打印的目的。所以可以增加一個(gè)條件變量，讓某個(gè)線(xiàn)程在該條件變量下的阻塞隊(duì)列等待。

C++庫(kù)中線(xiàn)程在條件變量下的等待函數(shù)第一個(gè)參數(shù)注意是管理鎖的類(lèi)對(duì)象

int main(void)
{
	int n = 100;
	int i = 0;
	mutex mtx;
	condition_variable cv;
	bool flag = false;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i, &mtx, &cv, &flag](){
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			//!flag為真，那么獲取后不會(huì)阻塞，優(yōu)先運(yùn)行
			cv.wait(LockManage, [&flag]() {return !flag; });
			cout << this_thread::get_id()  << ": " << i << endl;
			i++;
		}
	});
	thread t2([&n, &i, &mtx, &cv, &flag]() {
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			//flag為假，競(jìng)爭(zhēng)到鎖后，由于條件不滿(mǎn)足，阻塞
			cv.wait(LockManage, [&flag]() {return flag; });
			cout << this_thread::get_id() << ": " << i << endl;
			i++;
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

這里flag以及l(fā)ambda表達(dá)式的增加是非常巧妙的。flag的初始化值為false,讓線(xiàn)程t2在[&flag]() {return false; }下等待，那么t2線(xiàn)程就會(huì)先執(zhí)行。

線(xiàn)程t1競(jìng)爭(zhēng)到了鎖，但是由于不滿(mǎn)足條件，會(huì)繼續(xù)等待，所以就出現(xiàn)了上面的情況。

需要一個(gè)線(xiàn)程喚醒另一個(gè)線(xiàn)程之前，將flag的值進(jìn)行修改。

int main(void)
{
	int n = 100;
	int i = 0;
	mutex mtx;
	condition_variable cv;
	bool flag = false;
	//創(chuàng)建兩個(gè)線(xiàn)程
	thread t1([&n, &i, &mtx, &cv, &flag](){
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			//!flag為真，那么獲取后不會(huì)阻塞，優(yōu)先運(yùn)行
			cv.wait(LockManage, [&flag]() {return !flag; });
			cout << this_thread::get_id()  << ": " << i << endl;
			i++;
			flag = true;
			cv.notify_one();
		}
	});
	thread t2([&n, &i, &mtx, &cv, &flag]() {
		while (i < n)
		{
			unique_lock<mutex> LockManage(mtx);
			//flag為假，競(jìng)爭(zhēng)到鎖后，由于條件不滿(mǎn)足，阻塞
			cv.wait(LockManage, [&flag]() {return flag; });
			cout << this_thread::get_id() << ": " << i << endl;
			i++;
			flag = false;
			cv.notify_one();
		}
	});
	if (t1.joinable())
	{
		t1.join();
	}
	if (t2.joinable())
	{
		t2.join();
	}
	return 0;
}

最終，實(shí)現(xiàn)了兩個(gè)線(xiàn)程交替打?。ㄒ粋€(gè)線(xiàn)程打印奇數(shù)、一個(gè)線(xiàn)程打印偶數(shù)）