C++ åèæå
- C++11
- C++14
- C++17
- C++20
- C++ ç¼è¯å¨æ¯ææ åµè¡¨
- ç¬ç«ä¸å®¿ä¸»å®ç°
- C++ è¯è¨
- C++ å ³é®è¯
- é¢å¤çå¨
- C++ æ ååºå¤´æä»¶
- å ·åè¦æ±
- åè½ç¹æ§æµè¯ (C++20)
- å·¥å ·åº
- ç±»åæ¯æï¼åºæ¬ç±»åãRTTIãç±»åç¹æ§ï¼
- æ¦å¿µåº (C++20)
- é误å¤ç
- 卿å å管ç
- æ¥æåæ¶é´å·¥å ·
- å符串åº
- 容å¨åº
- è¿ä»£å¨åº
- èå´åº (C++20)
- ç®æ³åº
- æ°å¼åº
- è¾å ¥/è¾åºåº
- æä»¶ç³»ç»åº
- æ¬å°ååº
- æ£å表达å¼åº
- ååæä½åº
- çº¿ç¨æ¯æåº
- std::thread
- std::stop_token
- std::stop_source
- std::stop_callback
- std::this_thread::get_id
- std::shared_timed_mutex
- std::shared_lock
- std::lock_guard
- std::hardware_destructive_interference_size, std::hardware_constructive_interference_size
- std::counting_semaphore, std::binary_semaphore
- std::jthread
- cpp/thread/barrier
- std::future
- std::this_thread::yield
- std::this_thread::sleep_for
- std::this_thread::sleep_until
- std::mutex
- std::mutex::unlock
- std::mutex::lock
- std::recursive_mutex
- std::shared_mutex
- std::timed_mutex
- std::recursive_timed_mutex
- std::scoped_lock
- std::unique_lock
- std::defer_lock_t, std::try_to_lock_t, std::adopt_lock_t
- std::lock
- std::try_lock
- std::defer_lock, std::try_to_lock, std::adopt_lock
- std::once_flag
- std::call_once
- std::condition_variable
- std::condition_variable_any
- std::notify_all_at_thread_exit
- std::cv_status
- std::latch
- std::promise
- std::shared_future
- std::packaged_task
- std::async
- std::launch
- std::future_status
- std::future_error
- std::future_category
- std::future_errc
- 注é
- å®éªæ§ C++ ç¹æ§
- æç¨çèµæº
- ç´¢å¼
- std 符å·ç´¢å¼
- åç¨æ¯æ (C++20)
- C++ å ³é®è¯
ä½ç½®ï¼é¦é¡µ > C++ åèæå >çº¿ç¨æ¯æåº > std::mutex
std::mutex
| å®ä¹äºå¤´æä»¶ <mutex>
|
||
| class mutex; |
(C++11 èµ·) | |
mutex ç±»æ¯è½ç¨äºä¿æ¤å
±äº«æ°æ®å
åä»å¤ä¸ªçº¿ç¨åæ¶è®¿é®ç忥åè¯ã
mutex æä¾æä»æ§éé彿ææè¯ä¹ï¼
- è°ç¨æ¹çº¿ç¨ä»å®æåè°ç¨
lockætry_lockå¼å§ï¼å°å®è°ç¨unlock为æ¢å æmutexã - 线ç¨å æ
mutexæ¶ï¼ææå ¶ä»çº¿ç¨è¥è¯å¾è¦æ±mutexçæææï¼åå°é»å¡ï¼å¯¹äºlockçè°ç¨ï¼ææ¶å° false è¿åå¼ï¼å¯¹äºtry_lockï¼. - è°ç¨æ¹çº¿ç¨å¨è°ç¨
lockætry_lockåå¿ é¡»ä¸å æmutexã
è¥ mutex å¨ä»ä¸ºä»»ä½çº¿ç¨æå ææ¶å³è¢«éæ¯ï¼æå¨å æ mutex æ¶çº¿ç¨ç»æ¢ï¼åè¡ä¸ºæªå®ä¹ã mutex ç±»æ»¡è¶³äºæ¥ä½ (Mutex) åæ åå¸å±ç±»å (StandardLayoutType) çå
¨é¨è¦æ±ã
std::mutex æ¢ä¸å¯å¤å¶äº¦ä¸å¯ç§»å¨ã
æåç±»å
| Â | |
| æåç±»å | å®ä¹ |
native_handle_type(å¯é)
|
å®ç°å®ä¹ |
æå彿°
| æé äºæ¥ (å ¬å¼æå彿°) | |
| éæ¯äºæ¥ (å ¬å¼æå彿°) | |
| operator= [被å é¤] |
ä¸å¯å¤å¶èµå¼ (å ¬å¼æå彿°) |
éå® | |
| éå®äºæ¥ï¼è¥äºæ¥ä¸å¯ç¨åé»å¡ (å ¬å¼æå彿°) | |
| å°è¯éå®äºæ¥ï¼è¥äºæ¥ä¸å¯ç¨åè¿å (å ¬å¼æå彿°) | |
| è§£éäºæ¥ (å ¬å¼æå彿°) | |
åç奿 | |
| è¿ååºå±å®ç°å®ä¹çåç奿 (å ¬å¼æå彿°) | |
注æ
é常ä¸ç´æ¥ä½¿ç¨ std::mutex ï¼ std::unique_lock ã std::lock_guard æ std::scoped_lock (C++17 èµ·)以æ´å å¼å¸¸å®å
¨çæ¹å¼ç®¡çéå®ã
示ä¾
æ¤ç¤ºä¾å±ç¤º mutex è½å¦ä½ç¨äºå¨ä¿æ¤å
±äº«äºäºä¸ªçº¿ç¨é´ç std::map ã
è¿è¡æ¤ä»£ç
#include <iostream> #include <map> #include <string> #include <chrono> #include <thread> #include <mutex>  std::map<std::string, std::string> g_pages; std::mutex g_pages_mutex;  void save_page(const std::string &url) { // 模æé¿é¡µé¢è¯»å std::this_thread::sleep_for(std::chrono::seconds(2)); std::string result = "fake content";  std::lock_guard<std::mutex> guard(g_pages_mutex); g_pages[url] = result; }  int main() { std::thread t1(save_page, "http://foo"); std::thread t2(save_page, "http://bar"); t1.join(); t2.join();  // ç°å¨è®¿é®g_pagesæ¯å®å ¨çï¼å 为线ç¨t1/t2çå½å¨æå·²ç»æ for (const auto &pair : g_pages) { std::cout << pair.first << " => " << pair.second << '\n'; } }
è¾åºï¼
http://bar => fake content http://foo => fake content