C++中標準線程庫怎么使用

本文小編為大家詳細介紹“C++中標準線程庫怎么使用”，內容詳細，步驟清晰，細節處理妥當，希望這篇“C++中標準線程庫怎么使用”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。

1.創建線程異步執行

我們可以通過async函數直接異步創建一個線程,這種方法相對來說比較簡單,線程執行的結果可以直接用future<T>來進行獲取。

#include <iostream>
#include <future>
 
//線程對應的函數
bool thread_func(int x) {
	return true;
}
int main()
{
	int inputNum = 65547;
	std::future<bool> future = std::async(thread_func, inputNum);
	bool ret = future.get();
	getchar();
}

2.通過使用互斥鎖防止線程沖突

線程間同步讀取內容的話一般不會出現線程安全問題,但如果線程間同步寫同一個內容的話就容易出現沖突。比如每個線程執行一次,就會給全局執行次數累加一次,如果多個線程同時執行操作,在寫的時候沒有加鎖,這就有可能導致執行次數被重復累加的情況。

#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx; 
 
int count=0;
 
void print_block(int n) {
	mtx.lock();
   count++;
	//do somethings
	mtx.unlock();
}
int main()
{
	std::thread thread1(print_block, 50);
	std::thread thread2(print_block, 50);
 
	thread1.join();
	thread2.join();
	getchar();
	return 0;
}

3.采用信號量控制線程的運行

條件變量(condition_variable)用來控制線程的運行,線程啟動的時候如果條件變量等待,會阻塞線程的運行,直到條件變量發送對應的通知線程才能開始運行。通過采用條件變量我們可以控制線程的運行,避免線程空運行消耗計算資源。

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
 
std::mutex mtx;
std::condition_variable cv;
 
void print_id(int id) {
	std::unique_lock<std::mutex> lck(mtx);
	cv.wait(lck);
	std::cout << "thread " << id << '\n';
}
void go() {
	std::unique_lock<std::mutex> lck(mtx);
	cv.notify_all();
}
int main()
{
	std::thread threads[10];
	for (int i = 0; i < 10; ++i)
		threads[i] = std::thread(print_id, i);
   std::cout << "start thread run" << std::endl;
	go();
	for (auto& th : threads){th.join();}
	getchar();
	return 0;
}

4.通過promise實現進程間通信

很多時候線程間執行是有先后順序的,我們需要等待上一個線程執行結束拿到結果之后再執行當前線程,這時候就涉及到線程間的等待和數據傳遞這時候std::promise<T>就能排上用場了,通過使用該變量我們可以很輕松的實現線程間的等待和數據傳遞。

#include <iostream>
#include <future>
#include <chrono>
void Thread_Fun1(std::promise<int> &p)
{
	std::this_thread::sleep_for(std::chrono::seconds(5));
	int iVal = 233;
	std::cout << "傳入數據(int)：" << iVal << std::endl;
	p.set_value(iVal);
}
 
void Thread_Fun2(std::future<int> &f)
{
	//阻塞函數，直到收到相關聯的std::promise對象傳入的數據
	auto iVal = f.get();
	std::cout << "收到數據(int)：" << iVal << std::endl;
}
 
int main()
{
	std::promise<int> pr1;
	std::future<int> fu1 = pr1.get_future();
 
	std::thread t1(Thread_Fun1, std::ref(pr1));
	std::thread t2(Thread_Fun2, std::ref(fu1));
 
	//阻塞至線程結束
	t1.join();
	t2.join();
	return 1;
}

讀到這里，這篇“C++中標準線程庫怎么使用”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。