C++多線程快速入門(四)shared_mutex以及讀寫鎖應用

在前面的三講中我們使用的mutex都是普通的std::mutex,這里介紹一下shared_mutex,版本為C++17
std::shared_mutex的底層實現時操作系統提供的讀寫鎖,在讀多寫少的情況下,該shared_mutexmutex更加高效。

它提供了常用的四種方法:

lockunlock分別用于獲取寫鎖和解除寫鎖

lock_sharedunlock_shared分別用于獲取讀鎖和解除讀鎖

寫鎖模式稱為排他鎖,讀鎖模式稱為共享鎖。

c++11和c++14標準中分別引入unique_lockshared_lock兩個類模板配合shared_mutex使用。

對象在構造時自動對std::shared_mutex加鎖,析構時自動對其解鎖。

前者用于加解寫鎖,后者用于加解讀鎖。

當然在第二講中,我們也談到了unique_lock對于普通鎖mutex的一種應用,當時是和std::lock_guard對比的。
下面是案例代碼,對于共享資源我們創建多個讀線程和一個寫線程,分別使用std::mutexstd::shared_mutex做一下性能測試。

#include <iostream>
#include <thread>
#include <mutex>
#include <shared_mutex>// 讀線程數量
#define READER_THREAD_COUNT 4
// 最大循環次數
#define LOOP_COUNT 500000class shared_mutex_counter {
// 這里使用的鎖是 shared_mutex
private:mutable std::shared_mutex m_mutex;unsigned int m_value = 0;     // 多個線程共享的資源
public:shared_mutex_counter() = default;~shared_mutex_counter() = default;// shared_lock  同一時可多個讀線程可以同時訪問m_value的值unsigned int get() const{// 這里使用shared_lockstd::shared_lock<std::shared_mutex> lock(m_mutex);return m_value;}// unique_lock 同一時間僅有一個寫線程可以修改m_value的值void incremet() {std::unique_lock<std::shared_mutex> lock(m_mutex);m_value++;}
};class mutex_counter {
// 這里使用的鎖是 shared_mutex
private:mutable std::mutex m_mutex;unsigned int m_value = 0;     // 多個線程共享的資源
public:mutex_counter() = default;~mutex_counter() = default;// 同一時間僅有一個讀線程可以同時訪問m_value的值unsigned int get() const{std::unique_lock<std::mutex> lock(m_mutex);return m_value;}// 同一時間僅有一個寫線程可以修改m_value的值void incremet(){std::unique_lock<std::mutex> lock(m_mutex);m_value++;}
};// 測試 shared_mutex
void test_shared_mutex()
{shared_mutex_counter counter;unsigned int temp;// 寫線程函數auto write = [&counter]() {for (int i = 0; i < LOOP_COUNT; i++) {counter.incremet();}};// 讀線程函數auto read = [&counter, &temp]() {for (int i = 0; i < LOOP_COUNT; i++) {temp = counter.get();}};// 存放讀線程對象指針的數組std::thread** tarray = new std::thread* [READER_THREAD_COUNT];// 記錄起始時間clock_t start = clock();// 創建 READER_THREAD_COUNT 個讀線程for (int i = 0; i < READER_THREAD_COUNT; i++) {tarray[i] = new std::thread(read);}// 創建一個寫線程std::thread tw(write);// 等待joinfor (int i = 0; i < READER_THREAD_COUNT; i++) {tarray[i]->join();}tw.join();clock_t end = clock();std::cout << "test shared_mutex" << std::endl;std::cout << "thread count " << READER_THREAD_COUNT << std::endl;std::cout << "spend time " << end - start << std::endl;std::cout << "result : " << counter.get() << std::endl;std::cout << "temp : " << temp << std::endl;
}// 測試 mutex
void test_mutex()
{mutex_counter counter;unsigned int temp;// 寫線程函數auto write = [&counter]() {for (int i = 0; i < LOOP_COUNT; i++) {counter.incremet();}};// 讀線程函數auto read = [&counter, &temp]() {for (int i = 0; i < LOOP_COUNT; i++) {temp = counter.get();}};// 存放讀線程對象指針的數組std::thread** tarray = new std::thread* [READER_THREAD_COUNT];// 記錄起始時間clock_t start = clock();// 創建 READER_THREAD_COUNT 個讀線程for (int i = 0; i < READER_THREAD_COUNT; i++) {tarray[i] = new std::thread(read);}// 創建一個寫線程std::thread tw(write);// 等待joinfor (int i = 0; i < READER_THREAD_COUNT; i++) {tarray[i]->join();}tw.join();clock_t end = clock();std::cout << "test mutex" << std::endl;std::cout << "thread count " << READER_THREAD_COUNT << std::endl;std::cout << "spend time " << end - start << std::endl;std::cout << "result : " << counter.get() << std::endl;std::cout << "temp : " << temp << std::endl;
}int main() {test_mutex();std::cout << std::endl;test_shared_mutex();return 0;
}

測試結果如下:

test mutex
thread count 8
spend time 1312
result : 500000
temp : 500000test shared_mutex
thread count 8
spend time 601
result : 500000
temp : 475766

有個問題,我同樣程序在windows的clion和vs上跑結果差異較大,clion跑出來的結果shared_mutex耗時比mutex多好多。
linux下的vscode跑出來結果正常。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/376827.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/376827.shtml
英文地址,請注明出處:http://en.pswp.cn/news/376827.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

Tornado/Python 學習筆記(一)

1.源代碼下載及安裝&#xff1a;http://www.tornadoweb.org/en/stable/ 2.python中xmlrpc庫官方文檔&#xff1a;https://docs.python.org/3/library/xmlrpc.html?highlightxmlrpc 3.xml介紹與學習&#xff1a;http://www.w3school.com.cn/xml/xml_intro.asp XML 被設計為傳輸…

spring-aop-annotation

1。假設你已經配好依賴注入那一塊。此時的bean.xml為 <?xml version"1.0" encoding"UTF-8"?><beans xmlns"http://www.springframework.org/schema/beans"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xmlns:cont…

c++實現簡單線程池代碼

目錄完整代碼TaskPool.cppTaskPool.hmain.cpp完整代碼 TaskPool.cpp // // Created by LENOVO on 2021/10/25. //#include "TaskPool.h" #include <functional>std::mutex printMutex;TaskPool::TaskPool() : m_bRunning(false) {}TaskPool::~TaskPool() {re…

Android靜態圖片人臉識別的完整demo(附完整源碼)

Demo功能&#xff1a;利用android自帶的人臉識別進行識別&#xff0c;標記出眼睛和人臉位置。點擊按鍵后進行人臉識別&#xff0c;完畢后顯示到imageview上。 第一部分&#xff1a;布局文件activity_main.xml [html] view plaincopyprint?<RelativeLayout xmlns:android&qu…

圖論:最短路徑搜索--Dijkstra算法(c代碼實現)

最近因為辭職&#xff0c;有不少閑功夫&#xff0c;重溫下數據結構&#xff0c;順便練練手。今天說說最短路徑搜索算法中的Dijkstra原理和實現。 一&#xff1a;簡介 這個算法用于解決圖中單源最短路徑問題。所謂單源節點是指給定源節點&#xff0c;求圖中其它節點到此源節點的…

C++多線程快速入門(五)簡單線程池設計

目錄設計思路主線程運行邏輯task以及taskpool設計詳細流程講解完整代碼打印結果往期回顧設計思路 線程池實際上就是一組線程&#xff0c;當我們需要異步執行一些任務時&#xff0c;經常要通過OS頻繁創建和銷毀線程&#xff0c;不如直接創建一組在程序生命周期內不會退出的線程…

C--函數

函數:具有特定功能的代碼段,分為庫函數,自定義函數. 函數定義: 函數返回值類型 函數名(形式參數列表) { 代碼段; return 返回值; } 注意:每個函數返回值最多只有一個.return是一個函數結束的標志. 形式參數(形參):函數定義時使用的虛擬參數名,用以接收函數調用是傳遞過來的實際…

公式系統 - TradeBlazer公式基礎 - Bar數據

Bar數據 在介紹Bar數據之前&#xff0c;首先&#xff0c;我們需要討論一下TradeBlazer公式的計算方法&#xff0c;針對上面介紹的各種公式類型&#xff0c;包含公式應用&#xff0c;在公式進行計算時&#xff0c;都是建立在基本數據源(Bar數據)之上&#xff0c;我們這里所謂的B…

C++網絡編程快速入門(一):TCP網絡通信基本流程以及基礎函數使用

目錄流程概述服務器端代碼實現客戶端代碼實現函數和結構講解sockaddr_in和sockaddrsocket &#xff1a; 創建一個socket連接bind &#xff1a;綁定地址以及端口號問題流程概述 客戶端與服務器之間的網絡通信基本原理如下所示&#xff0c;復雜一點的架構可能會添加消息中間件。…

php 字符串處理

addcslashes — 為字符串里面的部分字符添加反斜線轉義字符addslashes — 用指定的方式對字符串里面的字符進行轉義bin2hex — 將二進制數據轉換成十六進制表示chop — rtrim() 的別名函數chr — 返回一個字符的ASCII碼chunk_split — 按一定的字符長度將字符串分割成小塊conve…

使用前端框架Foundation 4來幫助簡化響應式設計開發

日期&#xff1a;2013-3-12 來源&#xff1a;GBin1.com Foundation是一套使用廣泛的前端開發套件&#xff0c;可以幫助你快速的網站。最近ZURB發布了一個新版本的Foundation 4前端框架&#xff0c;能夠有效的幫助你快速的開發響應式的網站。 和另外一個套知名的前端框架BootSt…

C++網絡編程快速入門(二):Linux下使用select演示簡單服務端程序

目錄select參數解釋select使用規范select使用缺點基本流程實例代碼通信效果演示往期文章select參數解釋 extern int select (int __nfds, fd_set *__restrict __readfds,fd_set *__restrict __writefds,fd_set *__restrict __exceptfds,struct timeval *__restrict __timeout)…

Android轉載一:Android文件命名規范

REF&#xff1a;http://blog.csdn.net/gulianchao/article/details/23391651 (一) Layout命名 1&#xff0e;contentview命名&#xff1a;activity_功能模塊.xml 例如&#xff1a;activity_main.xml、activity_more.xml 2&#xff0e;Dialog命名&#xff1a;dialog_描述.xml …

[轉]XBRL應用軟件分類

1) 分類標準編輯軟件(Taxonomy editor)&#xff1a; 分類標準是XBRL技術的應用基礎&#xff0c;每一個采用XBRL技術的國家都必須先按各國的GAAP制訂XBRL分類標準&#xff0c;上市公司才能據以編制實例文件。由于一套XBRL 2.0或2.1版分類標準必須包含至少一份XML Schema文…

C++網絡編程快速入門(三):阻塞與非阻塞式調用網絡通信函數

目錄阻塞與非阻塞定義send與recvconnect一些問題為什么要將監聽socket設置為非阻塞阻塞與非阻塞定義 阻塞模式指的是當前某個函數執行效果未達預期&#xff0c;該函數會阻塞當前的執行線程&#xff0c;程序執行流在超時時間到達或者執行成功后恢復原有流程。非阻塞模式相反&am…

css3實現頭像旋轉360度

css樣式: .div a img{ width: 88px; height: 88px; border-radius: 88px; transition: all 1.2s ease-out 0s;}.div a img:hover{ -webkit-transform:rotate(360deg); -moz-transform:rotate(360deg); -o-transform:rotate(360deg); -ms-transform:rotate(360deg); transform:r…

POJ 2488 深搜

POJ 2488 深搜 要求字典序的順序。 1 #include <iostream>2 #include <stdio.h>3 #include <string.h>4 using namespace std;5 int n,m,cnt;6 bool success;7 bool sign[30][30];8 int step[30][2];9 int dir[8][2]{ 10 -2,-1,-2,1, 11 …

socket 端口和地址復用

https://blog.csdn.net/weibo1230123/article/details/79978745 https://blog.csdn.net/weixin_42157432/article/details/115560824 在linux socket網絡編程中&#xff0c;大規模并發TCP或UDP連接時&#xff0c;經常會用到端口復用&#xff1a; int opt 1; if (setsockopt…

MyEclipse老是彈出problem occurred窗口

有的時候是因為jsp頁面中的java腳本有誤&#xff0c;比如說<% String name"";>就會出現錯誤&#xff0c;因為結束標簽少了一個百分號&#xff05;。轉載于:https://www.cnblogs.com/passer1991/archive/2013/03/15/2961624.html

C++網絡編程快速入門(四):EPOLL模型使用

目錄基本使用方法step1:創建epollfdstep2:將fd綁定到epollfdstep3:調用epoll_wait檢測事件epoll_wait與poll、select區別所在水平觸發與邊緣觸發基本使用方法 step1:創建epollfd 創建一個epollfd&#xff0c;若epoll_create調用成功&#xff0c;則返回一個非負值的epollfd&am…