C++怎么实现一个读写锁_C++并发控制与std::shared_mutex应用

读写锁允许多个读线程并发访问,写线程独占访问,C++17的std::shared_mutex结合std::shared_lock和std::unique_lock可安全高效实现“读多写少”场景的同步。

在多线程编程中,读写锁(Reader-Writer Lock)是一种常见的同步机制,适用于“读多写少”的场景。它允许多个线程同时读取共享资源,但写操作必须独占访问。C++17 起提供了 std::shared_mutex,正好支持这种需求:多个读线程可以共享锁,而写线程需要独占锁。

std::shared_mutex 基本用法

std::shared_mutex 是 C++ 标准库中定义在 头文件中的类型,支持两种加锁方式:

  • 共享锁(shared lock):通过 lock_shared() 获取,允许多个线程同时持有,用于读操作。
  • 独占锁(exclusive lock):通过 lock() 获取,仅允许一个线程持有,用于写操作。

配合 RAII 管理的 std::shared_lockstd::unique_lock 使用更安全。

示例代码:

#include 
#include 
#include 
#include 
#include 

std::vector data = {1, 2, 3};
std::shared_mutex rw_mutex;

void reader(int id) {
    std::shared_lock lock(rw_mutex);
    std::cout << "Reader " << id << " sees data: ";
    for (int d : data) std::cout << d << " ";
    std::cout << "\n";
    std::this_thread::sleep_for(std::chrono::milliseconds(100)); // 模拟读耗时
}

void writer(int id) {
    std::unique_lock lock(rw_mutex);
    data.push_back(id);
    std::cout << "Writer " << id << " added " << id << "\n";
    std::this_thread::sleep_for(std::chrono::milliseconds(200));
}

// 启动多个读线程和写线程测试
std::vector threads;
for (int i = 0; i < 5; ++i) {
    threads.emplace_back(reader, i);
}
for (int i = 10; i < 12; ++i) {
    threads.emplace_back(writer, i);
}
for (auto& t : threads) t.join();

读写锁的核心优势

相比普通的互斥锁(std::mutex),读写锁在读频繁的场景下显著提升并发性能:

  • 多个读线程可并行执行,不阻塞彼此。
  • 写线程独占访问,确保数据一致性。
  • 读操作不会阻塞其他读操作,只被写操作阻塞。

这特别适合缓存、配置管理、状态查询等场景。

注意事项与最佳实践

虽然 std::shared_mutex 很实用,但使用时要注意以下几点:

  • 避免长时间持有写锁,否则会阻塞所有读操作。
  • 注意死锁风险,尤其是嵌套加锁或混合使用不同锁类型时。
  • 优先使用 std::shared_lockstd::unique_lock,它们能自动释放锁,防止异常导致的资源泄漏。
  • C++14 及以前版本没有 std::shared_mutex,可使用 Boost 库中的 boost::shared_mutex 替代。

基本上就这些。合理使用 std::shared_mutex 能有效提升多线程程序的吞吐量,尤其在读操作远多于写操作的场景下效果明显。关键是理解共享与独占的区别,并结合 RAII 保证安全。