C++怎么实现一个读写锁_C++并发编程与读写锁实现

答案是使用std::shared_mutex实现读写锁,允许多个读线程共享访问、写线程独占访问,提升读多写少场景的并发性能;C++17中通过lock_shared()和lock()分别获取读锁和写锁,配合std::shared_lock和std::unique_lock实现RAII管理,避免资源泄漏;若兼容C++11,则可用mutex与condition_variable手动实现读写状态控制,确保读时不写、写时互斥。

c++怎么实现一个读写锁_c++并发编程与读写锁实现

在C++中实现读写锁(Reader-Writer Lock),核心目标是允许多个读线程同时访问共享资源,但写线程独占访问。这种机制适用于“读多写少”的场景,能显著提升并发性能。

使用标准库的 shared_mutex 实现读写锁

C++17 起提供了 std::shared_mutex,天然支持读写锁语义:

  • 共享所有权(读锁):多个线程可同时获得共享锁(.lock_shared())
  • 独占所有权(写锁):仅一个线程可获得独占锁(.lock())
示例代码:

#include <shared_mutex><br>#include <thread><br>#include <vector><br>#include <iostream><br><br>std::shared_mutex rw_mutex;<br>int data = 0;<br><br>void reader(int id) {<br>    rw_mutex.lock_shared();<br>    std::cout << "Reader " << id << " reads data: " << data << "\n";<br>    rw_mutex.unlock_shared();<br>}<br><br>void writer(int id) {<br>    rw_mutex.lock();<br>    data += id;<br>    std::cout << "Writer " << id << " writes data: " << data << "\n";<br>    rw_mutex.unlock();<br>}<br><br>int main() {<br>    std::vector<std::thread> threads;<br>    for (int i = 0; i < 3; ++i) {<br>        threads.emplace_back(reader, i);<br>    }<br>    threads.emplace_back(writer, 10);<br>    threads.emplace_back(reader, 99);<br><br>    for (auto& t : threads) t.join();<br>    return 0;<br>}

输出中,多个读线程可能同时执行,而写线程会阻塞所有读操作。

手动实现简易读写锁(C++11 兼容)

若不能使用 C++17,可用互斥量和条件变量模拟读写锁逻辑。

基本思路:

Veed AI Voice Generator Veed AI Voice Generator

Veed推出的AI语音生成器

Veed AI Voice Generator 119 查看详情 Veed AI Voice Generator
  • std::mutex 保护读写状态
  • std::condition_variable 协调读写线程
  • 维护当前活跃读线程数和是否正在写
简化实现:

class ReadWriteLock {<br>private:<br>    std::mutex mtx;<br>    std::condition_variable cv;<br>    int readers{0};<br>    bool writing{false};<br><br>public:<br>    void lock_read() {<br>        std::unique_lock<std::mutex> lock(mtx);<br>        cv.wait(lock, [this] { return !writing; });<br>        readers++;<br>    }<br><br>    void unlock_read() {<br>        std::lock_guard<std::mutex> lock(mtx);<br>        readers--;<br>        if (readers == 0) cv.notify_all();<br>    }<br><br>    void lock_write() {<br>        std::unique_lock<std::mutex> lock(mtx);<br>        cv.wait(lock, [this] { return !writing && readers == 0; });<br>        writing = true;<br>    }<br><br>    void unlock_write() {<br>        std::lock_guard<std::mutex> lock(mtx);<br>        writing = false;<br>        cv.notify_all();<br>    }<br>};

使用时需注意避免死锁,比如不要在持有读锁时尝试获取写锁。

RAII 封装提升安全性

为避免忘记解锁,应使用 RAII 包装器:

  • std::shared_lock<:shared_mutex>:管理共享锁(读)
  • std::unique_lock<:shared_mutex>:管理独占锁(写)
示例:

std::shared_mutex rw_mutex;<br><br>void safe_read() {<br>    std::shared_lock lock(rw_mutex);<br>    // 自动加共享锁,作用域结束自动释放<br>    std::cout << "Reading: " << data << "\n";<br>}<br><br>void safe_write(int val) {<br>    std::unique_lock lock(rw_mutex);<br>    data = val;<br>}

RAII 是 C++ 并发编程的最佳实践,极大降低资源管理错误风险。

基本上就这些。优先使用 std::shared_mutex + std::shared_lock/unique_lock,简洁高效。若需兼容旧标准,可手写基于 condition_variable 的版本,但务必测试竞争边界情况。

以上就是C++怎么实现一个读写锁_C++并发编程与读写锁实现的详细内容,更多请关注其它相关文章!

本文转自网络,如有侵权请联系客服删除。