快捷導(dǎo)航

C++鎖機(jī)制與信號(hào)機(jī)制對(duì)比分析

更新時(shí)間：2025年06月21日 11:26:40 作者：張新顏

文章介紹C++多線程編程中線程同步與通信的鎖機(jī)制（互斥鎖、讀寫(xiě)鎖及RAII封裝）和信號(hào)機(jī)制（條件變量、信號(hào)量）,并對(duì)比其在資源控制、并發(fā)限制和線程協(xié)調(diào)中的應(yīng)用場(chǎng)景與優(yōu)缺點(diǎn),對(duì)C++鎖機(jī)制與信號(hào)機(jī)制相關(guān)知識(shí)感興趣的朋友一起看看吧

前言

在C++中，多線程編程的線程同步和通信主要依賴于鎖機(jī)制和信號(hào)機(jī)制。

一、鎖機(jī)制

鎖用于控制對(duì)共享資源的訪問(wèn)，防止多個(gè)線程同時(shí)修改數(shù)據(jù)導(dǎo)致競(jìng)態(tài)條件。

互斥鎖（Mutex）
作用：確保同一時(shí)間只有一個(gè)線程能訪問(wèn)共享資源。
類(lèi)型：
○ std::mutex：基本互斥鎖。
○ std::recursive_mutex：允許同一線程多次加鎖（解決遞歸調(diào)用中的鎖問(wèn)題）。
○ std::shared_mutex（C++17）：讀寫(xiě)鎖，允許多個(gè)讀線程或單個(gè)寫(xiě)線程訪問(wèn)。

基本用法

#include <mutex>
std::mutex mtx;
void thread_func() {
    mtx.lock();
    // 訪問(wèn)共享資源
    mtx.unlock();
}

RAII包裝器（推薦使用，避免手動(dòng)解鎖）：
std::lock_guard：自動(dòng)在作用域內(nèi)加鎖和解鎖。

{
    std::lock_guard<std::mutex> lock(mtx);
    // 自動(dòng)加鎖，離開(kāi)作用域自動(dòng)解鎖
}

std::unique_lock：更靈活，支持延遲加鎖和手動(dòng)控制。

std::unique_lock<std::mutex> lock(mtx, std::defer_lock);
lock.lock(); // 手動(dòng)加鎖
// ...
lock.unlock(); // 可提前解鎖

讀寫(xiě)鎖（Shared Mutex）
適用場(chǎng)景：讀多寫(xiě)少的情況，提高并發(fā)性能。
用法：

#include <shared_mutex>
std::shared_mutex rw_mtx;
// 讀操作（共享鎖）
{
    std::shared_lock<std::shared_mutex> lock(rw_mtx);
    // 多個(gè)讀線程可同時(shí)訪問(wèn)
}
// 寫(xiě)操作（獨(dú)占鎖）
{
    std::unique_lock<std::shared_mutex> lock(rw_mtx);
    // 僅一個(gè)寫(xiě)線程可訪問(wèn)
}

死鎖預(yù)防
原則：
a. 按固定順序加鎖。
b. 使用std::lock同時(shí)加多個(gè)鎖（避免死鎖）。

std::lock(mtx1, mtx2); // 原子性鎖定多個(gè)互斥量
std::lock_guard<std::mutex> lock1(mtx1, std::adopt_lock);
std::lock_guard<std::mutex> lock2(mtx2, std::adopt_lock);

二、信號(hào)機(jī)制（條件變量）

核心操作
等待（Wait）：線程在條件不滿足時(shí)掛起。通知（Notify）：條件滿足時(shí)喚醒等待的線程。
notify_one()：?jiǎn)拘岩粋€(gè)等待線程。
notify_all()：?jiǎn)拘阉械却€程。
基本用法等待條件（需配合互斥鎖和謂詞檢查）：

std::mutex mtx;
std::condition_variable cv;
bool data_ready = false;
// 等待線程
{
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [] { return data_ready; }); // 防止虛假喚醒
    // 條件滿足后執(zhí)行操作
}
// 通知線程
{
    std::lock_guard<std::mutex> lock(mtx);
    data_ready = true;
    cv.notify_one(); // 或 notify_all()
}

避免虛假喚醒
使用帶有謂詞檢查的wait：

cv.wait(lock, predicate); // 等價(jià)于 while (!predicate) cv.wait(lock);

三、信號(hào)量（Semaphore）

C++20 引入了std::counting_semaphore，用于控制同時(shí)訪問(wèn)資源的線程數(shù)量。

基本用法

#include <semaphore>
std::counting_semaphore<10> sem(3); // 最大計(jì)數(shù)10，初始3
sem.acquire(); // 計(jì)數(shù)減1（如果計(jì)數(shù)為0則阻塞）
// 訪問(wèn)資源
sem.release(); // 計(jì)數(shù)加1