快捷導(dǎo)航

C++鎖機(jī)制與信號機(jī)制對比分析

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

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

前言

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

一、鎖機(jī)制

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

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

基本用法

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

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

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

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

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

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

#include <shared_mutex>
std::shared_mutex rw_mtx;
// 讀操作（共享鎖）
{
    std::shared_lock<std::shared_mutex> lock(rw_mtx);
    // 多個讀線程可同時訪問
}
// 寫操作（獨占鎖）
{
    std::unique_lock<std::shared_mutex> lock(rw_mtx);
    // 僅一個寫線程可訪問
}

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

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

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

核心操作
等待（Wait）：線程在條件不滿足時掛起。通知（Notify）：條件滿足時喚醒等待的線程。
notify_one()：喚醒一個等待線程。
notify_all()：喚醒所有等待線程。
基本用法等待條件（需配合互斥鎖和謂詞檢查）：

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); // 等價于 while (!predicate) cv.wait(lock);

三、信號量（Semaphore）

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

基本用法

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