如何在 c++++ 函数中实现线程安全的数据结构?使用互斥锁保护临界区(共享数据)。线程安全的动态数组示例:使用互斥锁保护 std::vector 中的数据。实战案例:线程安全的队列,使用互斥锁和条件变量实现消息队列的线程安全。
如何在 C++ 函数中实现线程安全的数据结构?
在多线程应用程序中,并发访问共享数据可能会导致竞态条件和数据损坏。因此,至关重要的是对共享的数据结构进行线程安全,以确保每个线程都能安全地访问和修改数据。
实现线程安全数据结构的一种简单方法是使用互斥锁。互斥锁是一种同步原语,它允许一次只有一个线程访问临界区(共享数据)。以下代码示例展示了如何使用互斥锁保护动态数组中的数据:
#include <mutex> #include <vector> std::mutex m; // 线程安全的动态数组 class ThreadSafeVector { public: void push_back(int value) { std::lock_guard<std::mutex> lock(m); v.push_back(value); } int get(size_t index) { std::lock_guard<std::mutex> lock(m); return v[index]; } private: std::vector<int> v; }; int main() { ThreadSafeVector v; v.push_back(1); int value = v.get(0); // ... }